trlopes1974 commented on issue #39717:
URL: https://github.com/apache/airflow/issues/39717#issuecomment-2245721663
humm:
Task Log:
[2024-07-23, 16:45:35 WEST] {standard_task_runner.py:63} INFO - Started
process **4029044** to run task
[2024-07-23, 16:45:35 WEST] {standard_task_runner.py:90} INFO - Running:
['airflow', 'tasks', 'run', 'CS00007002_Correcao_Dados_Oracle',
'remote_actions.ssh_command_remove_operator',
'CS00007002_Correcao_Dados_Oracle_WO0000000812045_2024-07-23T16:44:06.792767+01:00',
'--job-id', '476850', '--raw', '--subdir',
'DAGS_FOLDER/CS00007002_Correcao_Dados_Oracle.py', '--cfg-path',
'/tmp/tmpjgcjenx6']
[2024-07-23, 16:45:35 WEST] {standard_task_runner.py:91} INFO - Job 476850:
Subtask remote_actions.ssh_command_remove_operator
this started 4029044 PID. The task result in Airflow is this (SUCCESS):
[2024-07-23, 16:45:36 WEST] {taskinstance.py:1206} INFO - Marking task as
SUCCESS. dag_id=CS00007002_Correcao_Dados_Oracle,
task_id=remote_actions.ssh_command_remove_operator,
run_id=CS00007002_Correcao_Dados_Oracle_WO0000000812045_2024-07-23T16:44:06.792767+01:00,
execution_date=20240723T154406, start_date=20240723T154535,
end_date=20240723T154536
Now, in Flower (hours in UTC here -1h than our localtime) :
Failed 2024-07-23 15:45:36.611373 UTC
Retries 0
Worker
[celery@slautop02](https://flower.slautop02.knb:5555/worker/celery%40slautop02)
Exception AirflowException('Celery command failed on host: slautop02 with
celery_task_id 12d04460-140e-47e3-a184-cb4ed7896697 (PID: 4029004, Return Code:
256)')
Timestamp 2024-07-23 15:45:36.611373 UTC
Traceback
Traceback (most recent call last):
File
"/opt/tkapp/env_airflow/lib64/python3.9/site-packages/celery/app/trace.py",
line 453, in trace_task
R = retval = fun(*args, **kwargs)
File
"/opt/tkapp/env_airflow/lib64/python3.9/site-packages/celery/app/trace.py",
line 736, in __protected_call__
return self.run(*args, **kwargs)
File
"/opt/tkapp/env_airflow/lib64/python3.9/site-packages/airflow/providers/celery/executors/celery_executor_utils.py",
line 136, in execute_command
_execute_in_fork(command_to_exec, celery_task_id)
File
"/opt/tkapp/env_airflow/lib64/python3.9/site-packages/airflow/providers/celery/executors/celery_executor_utils.py",
line 154, in _execute_in_fork
raise AirflowException(msg)
airflow.exceptions.AirflowException: Celery command failed on host:
slautop02 with celery_task_id 12d04460-140e-47e3-a184-cb4ed7896697 (PID:
4029004, Return Code: 256)
The same PID 4029004 is turns the celery task to be marked as failed!
--
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]
