wjddn279 commented on code in PR #66141:
URL: https://github.com/apache/airflow/pull/66141#discussion_r3307696240
##########
task-sdk/src/airflow/sdk/execution_time/callback_supervisor.py:
##########
@@ -356,6 +357,15 @@ def supervise_callback(
logger = structlog.get_logger(logger_name="callback").bind()
with _ensure_client(server, token, client=client) as client:
+ # Mark the callback as RUNNING via the API. This is the single endpoint
+ # that accepts a workload-scoped token; it returns a fresh execution
+ # token via the Refreshed-API-Token header which the Client's response
+ # hook adopts automatically for the rest of the run.
+ client.callbacks.start(id)
Review Comment:
thanks. take option2
--
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]
