vdusek commented on pull request #6722:
URL: https://github.com/apache/airflow/pull/6722#issuecomment-877108743


   
   ```
   [2021-07-09 10:00:54,945: ERROR/ForkPoolWorker-32] Failed to execute task 
dag_id could not be found: dm-bi-edw-c360-export-brg. Either the dag did not 
exist or it failed to parse..
   Traceback (most recent call last):
     File 
"/usr/local/lib/python3.7/site-packages/airflow/executors/celery_executor.py", 
line 117, in _execute_in_fork
       args.func(args)
     File "/usr/local/lib/python3.7/site-packages/airflow/cli/cli_parser.py", 
line 48, in command
       return func(*args, **kwargs)
     File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 
91, in wrapper
       return f(*args, **kwargs)
     File 
"/usr/local/lib/python3.7/site-packages/airflow/cli/commands/task_command.py", 
line 220, in task_run
       dag = get_dag(args.subdir, args.dag_id)
     File "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 
193, in get_dag
       'parse.'.format(dag_id)
   airflow.exceptions.AirflowException: dag_id could not be found: 
dm-bi-edw-c360-export-brg. Either the dag did not exist or it failed to parse.
   [2021-07-09 10:00:54,979: ERROR/ForkPoolWorker-32] Task 
airflow.executors.celery_executor.execute_command[22a8df15-e32b-4719-a681-7c65fec9cb5e]
 raised unexpected: AirflowException('Celery command failed on host: 
172.20.38.183')
   Traceback (most recent call last):
     File "/usr/local/lib/python3.7/site-packages/celery/app/trace.py", line 
412, in trace_task
       R = retval = fun(*args, **kwargs)
     File "/usr/local/lib/python3.7/site-packages/celery/app/trace.py", line 
704, in __protected_call__
       return self.run(*args, **kwargs)
     File 
"/usr/local/lib/python3.7/site-packages/airflow/executors/celery_executor.py", 
line 88, in execute_command
       _execute_in_fork(command_to_exec)
     File 
"/usr/local/lib/python3.7/site-packages/airflow/executors/celery_executor.py", 
line 99, in _execute_in_fork
       raise AirflowException('Celery command failed on host: ' + 
get_hostname())
   airflow.exceptions.AirflowException: Celery command failed on host: 
172.20.38.183
   ```
   
   Which is interesting. I checked it and DAGs are (were) there and there's no 
problem with their parsing.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to