@@ -51,8 +51,12 @@ def create_rolebinding(rbac_v1, namespace):
5151
5252
5353def container_env (client , spec , cronjob_name ):
54- buckets = spec ["buckets" ]
55- buckets_string = "," .join (buckets )
54+ bucket_names = [b ["name" ] for b in spec ["buckets" ]]
55+ buckets_string = "," .join (bucket_names )
56+
57+ # sync buckets
58+ sync_buckets = [b ["name" ] for b in spec ["buckets" ] if b .get ("sync" )]
59+ sync_string = "," .join (sync_buckets )
5660 jobs = str (spec ["jobs" ])
5761 dry_run = str (spec ["dry-run" ])
5862 env = [
@@ -121,6 +125,7 @@ def container_env(client, spec, cronjob_name):
121125 client .V1EnvVar (name = "MEMORY_REQUEST" , value = spec ["request" ]["memory" ]),
122126 client .V1EnvVar (name = "CPU_REQUEST" , value = spec ["request" ]["cpu" ]),
123127 client .V1EnvVar (name = "BUCKET_LIST" , value = buckets_string ),
128+ client .V1EnvVar (name = "SYNC_LIST" , value = sync_string ),
124129 client .V1EnvVar (name = "PARENT_NAME" , value = cronjob_name ),
125130 client .V1EnvVar (name = "DRY_RUN" , value = dry_run ),
126131 client .V1EnvVar (
0 commit comments