@@ -640,11 +640,11 @@ def add_idds_work(config, generic_workflow, idds_workflow):
640640 if enable_event_service :
641641 enable_event_service = enable_event_service .split ("," )
642642 enable_event_service_tmp = []
643- for i in enable_event_service :
644- if ":" in i :
645- es_label , m_payloads = i .split (":" )
643+ for es_def in enable_event_service :
644+ if ":" in es_def :
645+ es_label , m_payloads = es_def .split (":" )
646646 else :
647- es_label , m_payloads = i , max_payloads_per_panda_job
647+ es_label , m_payloads = es_def , max_payloads_per_panda_job
648648 es_label = es_label .strip ()
649649 enable_event_service_tmp .append (es_label )
650650 max_payloads_per_panda_job_by_label [es_label ] = int (m_payloads )
@@ -719,7 +719,7 @@ def add_idds_work(config, generic_workflow, idds_workflow):
719719 if enable_event_service and job_label in enable_event_service :
720720 work_enable_event_service = True
721721 max_payloads_per_panda_job_current = max_payloads_per_panda_job_by_label .get (
722- job_label , PANDA_DEFAULT_MAX_PAYLOADS_PER_PANDA_JOB
722+ job_label , max_payloads_per_panda_job
723723 )
724724 work , files = _make_doma_work (
725725 config ,
0 commit comments