@@ -27,14 +27,19 @@ def chunk_partners(config, jobs):
2727 dep_job = get_primary_dependency (config , job )
2828 assert dep_job
2929
30+ print ("job" , config .kind , job )
31+
3032 build_platform = dep_job .attributes ["build_platform" ]
3133 repack_id = dep_job .task .get ("extra" , {}).get ("repack_id" )
3234 repack_ids = dep_job .task .get ("extra" , {}).get ("repack_ids" )
3335 copy_repack_ids = job .pop ("copy-repack-ids" , False )
3436
37+ print ("job2" , config .kind , job )
38+
3539 if copy_repack_ids :
3640 assert repack_ids , f"dep_job { dep_job .label } doesn't have repack_ids!"
3741 job .setdefault ("extra" , {})["repack_ids" ] = repack_ids
42+ print ("job yield copy_repack_ids" , config .kind , job )
3843 yield job
3944 # first downstream of the repack task, no chunking or fanout has been done yet
4045 elif not any ([repack_id , repack_ids ]):
@@ -45,6 +50,8 @@ def chunk_partners(config, jobs):
4550 "release-eme-free-repack-signing" ,
4651 "release-eme-free-repack-mac-signing" ,
4752 "release-partner-repack-mac-signing" ,
53+ "enterprise-repack-signing" ,
54+ "enterprise-repack-mac-signing" ,
4855 ):
4956 repacks_per_chunk = job .get ("repacks-per-chunk" )
5057 chunks , remainder = divmod (len (platform_repack_ids ), repacks_per_chunk )
@@ -55,22 +62,26 @@ def chunk_partners(config, jobs):
5562 partner_job = copy .deepcopy (job )
5663 partner_job .setdefault ("extra" , {}).setdefault ("repack_ids" , chunk )
5764 partner_job ["extra" ]["repack_suffix" ] = str (this_chunk )
65+ print ("job partner_job" , config .kind , job )
5866 yield partner_job
5967 # linux and windows we fan out immediately to one task per partner-sub_partner-locale
6068 else :
6169 for repack_id in platform_repack_ids :
6270 partner_job = copy .deepcopy (job ) # don't overwrite dict values here
6371 partner_job .setdefault ("extra" , {})
6472 partner_job ["extra" ]["repack_id" ] = repack_id
73+ print ("job partner_job 2" , config .kind , job )
6574 yield partner_job
6675 # fan out chunked mac signing for repackage
6776 elif repack_ids :
6877 for repack_id in repack_ids :
6978 partner_job = copy .deepcopy (job )
7079 partner_job .setdefault ("extra" , {}).setdefault ("repack_id" , repack_id )
80+ print ("job partner_job 3" , config .kind , job )
7181 yield partner_job
7282 # otherwise we've fully fanned out already, continue by passing repack_id on
7383 else :
7484 partner_job = copy .deepcopy (job )
7585 partner_job .setdefault ("extra" , {}).setdefault ("repack_id" , repack_id )
86+ print ("job partner_job 4" , config .kind , job )
7687 yield partner_job
0 commit comments