Skip to content

Commit

Permalink
Remove redundant vars from supervisor code (#44974)
Browse files Browse the repository at this point in the history
Afer we moved `resp = None` at the top-level, we don't need this.
  • Loading branch information
kaxil authored Dec 17, 2024
1 parent 89fdc03 commit 8848d6e
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions task_sdk/src/airflow/sdk/execution_time/supervisor.py
Original file line number Diff line number Diff line change
Expand Up @@ -698,13 +698,10 @@ def _handle_request(self, msg, log):
elif isinstance(msg, DeferTask):
self._terminal_state = IntermediateTIState.DEFERRED
self.client.task_instances.defer(self.id, msg)
resp = None
elif isinstance(msg, SetXCom):
self.client.xcoms.set(msg.dag_id, msg.run_id, msg.task_id, msg.key, msg.value, msg.map_index)
resp = None
elif isinstance(msg, PutVariable):
self.client.variables.set(msg.key, msg.value, msg.description)
resp = None
else:
log.error("Unhandled request", msg=msg)
return
Expand Down

0 comments on commit 8848d6e

Please sign in to comment.