Skip to content

Commit 2e700dc

Browse files
authored
fix(hitl): fix HITLTrigger params dump (#58297)
1 parent 77906c1 commit 2e700dc

File tree

1 file changed

+2
-2
lines changed
  • providers/standard/src/airflow/providers/standard/triggers

1 file changed

+2
-2
lines changed

providers/standard/src/airflow/providers/standard/triggers/hitl.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ async def run(self) -> AsyncIterator[TriggerEvent]:
266266
resp = await sync_to_async(update_hitl_detail_response)(
267267
ti_id=self.ti_id,
268268
chosen_options=self.defaults,
269-
params_input=self.params,
269+
params_input=self.params.dump(),
270270
)
271271
if TYPE_CHECKING:
272272
assert resp.responded_at is not None
@@ -276,7 +276,7 @@ async def run(self) -> AsyncIterator[TriggerEvent]:
276276
yield TriggerEvent(
277277
HITLTriggerEventSuccessPayload(
278278
chosen_options=self.defaults,
279-
params_input=self.params,
279+
params_input=self.params.dump(),
280280
responded_by_user=None,
281281
responded_at=resp.responded_at,
282282
timedout=True,

0 commit comments

Comments
 (0)