-
Notifications
You must be signed in to change notification settings - Fork 54
Open
Description
I have some doubts about fref batching=True and fref.type=MULTIEXEC. In executor/server.py, when the executor receives exec_dag_socket, if batching=True, so I see that multiple trigger information will be obtained. At this time, if the type of fref is MULTIEXEC, [trigger] is assigned to triggers in the code. The trigger here is the last socket information in the previous loop, and the value of trigger is not updated in the subsequent loop, which will cause the following The same trigger value is used for each call. I wonder if there is a problem with my understanding?I pasted the code snippet at the back.Thanks for your help.
for key in trigger_keys:
# print(key)
# print(received_triggers[key])
# print(trigger)
if (len(received_triggers[key]) == len(schedule.triggers)) or fref.type == MULTIEXEC:
if fref.type == MULTIEXEC:
triggers = [trigger]
else:
triggers = list(received_triggers[key].values())
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels