@@ -325,6 +325,7 @@ def create_k8s_deployment(email, workflow_info, runtime, management=False):
325325 if not management :
326326 if "workflowMetadata" in workflow_info and "knative" in workflow_info ["workflowMetadata" ]:
327327 knative_groups = workflow_info ["workflowMetadata" ]["knative" ]
328+ print ("[kservice update]: User provided kservice metadata: " + str (knative_groups ))
328329 for group_name in ["annotations" , "container" , "spec" ]:
329330 if group_name not in knative_groups :
330331 continue
@@ -339,17 +340,23 @@ def create_k8s_deployment(email, workflow_info, runtime, management=False):
339340
340341 assert (type (group_to_update ) == type ({}))
341342 group = knative_groups [group_name ]
343+ print ("[kservice update]: Updating group: " + group_name + ", current value: " + str (group_to_update ))
344+ print ("[kservice update]: User provided group value: " + str (group ))
342345 # group = the user provided new info for a group, group_to_update = the existing group to update
343346 for user_provided_value_key in group :
344347 # env variables should be appended
345348 if group_name is "container" and user_provided_value_key is "env" :
346349 if user_provided_value_key in group_to_update and type (group [user_provided_value_key ]) is type ([]) and len (group [user_provided_value_key ]) > 0 :
350+ print ("[kservice update]: Updating env variables" )
347351 for env_key_val in group [user_provided_value_key ]:
348- group_to_update [user_provided_value_key ].append (env_key_val )
352+ print ("[kservice update]: env: appending: " + str (env_key_val ))
353+ env .append (env_key_val )
349354 else :
350355 # overwrite or add the user provided key value
356+ print ("[kservice update]: Updating " + str (user_provided_value_key ))
351357 group_to_update [user_provided_value_key ] = group [user_provided_value_key ]
352- print ('Updated Knative service definition to: ' + str (kservice ))
358+ print ("[kservice update]: Updated group: " + group_name + ", updated value: " + str (group_to_update ))
359+ print ('[kservice update]: Updated Knative service definition to: ' + str (kservice ))
353360
354361
355362 print ('Checking if kservice exists' )
0 commit comments