[GitHub] [airflow] ian-byrne edited a comment on issue #16025: AirflowException: Celery command failed on host: [...]

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

ian-byrne edited a comment on issue #16025:
URL: https://github.com/apache/airflow/issues/16025#issuecomment-888489320


   I am having a similar issue where all celery tasks are marked as state=Failure. All of the tasks are success in the Airflow UI and appear to have worked proper with moving data to the database. The celery error found in flower is as follows: 
   ```
   Traceback (most recent call last):   
     File "/home/airflow/.local/lib/python3.6/site-packages/celery/app/trace.py", line 412, in trace_task     
        R = retval = fun(*args, **kwargs)   
     File "/home/airflow/.local/lib/python3.6/site-packages/celery/app/trace.py", line 704, in __protected_call__     
       return self.run(*args, **kwargs)   
     File "/home/airflow/.local/lib/python3.6/site-packages/airflow/executors/celery_executor.py", line 88, in execute_command     
       _execute_in_fork(command_to_exec)   
     File "/home/airflow/.local/lib/python3.6/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: 380778ca99d1
   --
   ```
   
   EDIT: after poking around a bit longer it looks like cloudwatch integration could be the issue #13824 


-- 
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