Roman Opeida

The same issue here with 2.10.3 and CeleryExecutor. Worker log: > Nov 29 01:04:05 ubuntu-s-4vcpu-8gb-amd-fra1-01 airflow[2929312]: [2024-11-29T01:04:05.161+0000] {scheduler_job_runner.py:910} ERROR - Executor CeleryExecutor(parallelism=64) reported that the task instance finished with state...

I also confirm that some DAGs randomly disappear, and dag-processor errors lead to this issue. It is the main reason why we cannot move the production environment to v3. I...

@kaxil sure! Just an important notice here: the mentioned problem was observed on 3.0.3. I will update my environment to 3.0.4 and come back with the results. ### Problem description...

> [@opeida](https://github.com/opeida) The ideal way would be to not access Variables or Connections at the top of your file (i.e outside Task Context) @kaxil are there workarounds to eliminate the...

> py_func = PythonOperator( > task_id="py_func", > python_callable=my_function, > op_kwargs={ > "my_var": "{{ var.value." + provider_name + "_accounts }}" > } > ) @kaxil the provided DAG reproduces the issue...