I agree to follow this project's Code of Conductīeta Was this translation helpful? Give feedback. Code Pull requests Discussions Actions Security main airflow/airflow/executors/kubernetesexecutor.py Go to file Cannot retrieve contributors at this time 1050 lines (939 sloc) 44 KB Raw Blame Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.No response Are you willing to submit PR? Slight modified airflow helm charts Anything else Log.info("run date is : " + str(run_date))į.write("Now the file has more content!")ĭocker/Kubernetes Versions of Apache Airflow Providers Google Kubernetes Engine pods are subject. Task fails without emitting logs due to Pod eviction. LOGGER = logging.getLogger("airflow.task") In Cloud Composer 2, increase memory limits for Airflow workers. ![]() Log: logging.log = logging.getLogger("airflow") ![]() Logging_config_class = log_config.LOGGING_CONFIGĮxtra_logger_names = connexion,sqlalchemyĬolored_log_format = įrom import PythonOperatorįrom kubernetes.client import models as k8s incluster (bool) run kubernetes client with incluster configuration clustercontext (string) context that points to kubernetes cluster. Still, the airflow-scheduler pod crashes due to permission errors as i cannot write in the mounted logs folder: logs here.
0 Comments
Leave a Reply. |