[GitHub] [airflow] vdusek edited a comment on pull request #6722: [AIRFLOW-4922]Fix task get log by Web UI

[GitBox <gi...@apache.org>]

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


   @ashb 
   ```
   [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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org