vatsrahul1001 commented on issue #48538:
URL: https://github.com/apache/airflow/issues/48538#issuecomment-2764402660
I see error in celery worker logs
```
[2025-03-30T05:59:38.340+0000] {trace.py:267} ERROR - Task
execute_workload[c3a1a240-ecb4-447a-a7d5-1c90d9c8531e] raised unexpected:
ServerResponseError('Server returned error')
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/celery/app/trace.py", line
453, in trace_task
R = retval = fun(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/celery/app/trace.py", line
736, in __protected_call__
return self.run(*args, **kwargs)
File
"/opt/airflow/providers/celery/src/airflow/providers/celery/executors/celery_executor_utils.py",
line 161, in execute_workload
supervise(
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 1153, in supervise
exit_code = process.wait()
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 730, in wait
self._monitor_subprocess()
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 788, in _monitor_subprocess
alive = self._service_subprocess(max_wait_time=max_wait_time) is None
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 625, in _service_subprocess
need_more = socket_handler(key.fileobj)
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 1010, in cb
gen.send(line)
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 514, in handle_requests
self._handle_request(msg, log)
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 916, in _handle_request
self.client.xcoms.set(
File "/opt/airflow/task-sdk/src/airflow/sdk/api/client.py", line 332, in
set
self.client.post(f"xcoms/{dag_id}/{run_id}/{task_id}/{key}",
params=params, json=value)
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 1145,
in post
return self.request(
File "/usr/local/lib/python3.9/site-packages/tenacity/__init__.py", line
336, in wrapped_f
return copy(f, *args, **kw)
File "/usr/local/lib/python3.9/site-packages/tenacity/__init__.py", line
475, in __call__
do = self.iter(retry_state=retry_state)
File "/usr/local/lib/python3.9/site-packages/tenacity/__init__.py", line
376, in iter
result = action(retry_state)
File "/usr/local/lib/python3.9/site-packages/tenacity/__init__.py", line
398, in <lambda>
self._add_action_func(lambda rs: rs.outcome.result())
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 439, in
result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 391, in
__get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/tenacity/__init__.py", line
478, in __call__
result = fn(*args, **kwargs)
File "/opt/airflow/task-sdk/src/airflow/sdk/api/client.py", line 538, in
request
return super().request(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 827,
in request
return self.send(request, auth=auth, follow_redirects=follow_redirects)
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 914,
in send
response = self._send_handling_auth(
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 942,
in _send_handling_auth
response = self._send_handling_redirects(
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 999,
in _send_handling_redirects
raise exc
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 982,
in _send_handling_redirects
hook(response)
File "/opt/airflow/task-sdk/src/airflow/sdk/api/client.py", line 107, in
raise_on_4xx_5xx
return get_json_error(response) or response.raise_for_status()
File "/opt/airflow/task-sdk/src/airflow/sdk/api/client.py", line 103, in
get_json_error
raise err
airflow.sdk.api.client.ServerResponseError: Server returned error
[2025-03-30 05:59:41 +0000] [171] [INFO] Handling signal: winch
[2025-03-30 06:01:39 +0000] [171] [INFO] Handling signal: winch
```
--
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]
