Skip to content

Commit 152cec1

Browse files
committed
CH-188 feat: Add more flexibility to on_exit_notify
1 parent ecfc86a commit 152cec1

1 file changed

Lines changed: 13 additions & 5 deletions

File tree

  • libraries/cloudharness-common/cloudharness/workflows

libraries/cloudharness-common/cloudharness/workflows/operations.py

Lines changed: 13 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -169,14 +169,22 @@ def spec(self):
169169
return spec
170170

171171
def add_on_exit_notify_handler(self, spec):
172-
queue = self.on_exit_notify['queue']
173-
payload = self.on_exit_notify['payload']
172+
env_args = {
173+
'workflow_result': '{{workflow.status}}'
174+
}
175+
176+
if 'queue' in self.on_exit_notify:
177+
env_args['queue_name'] = self.on_exit_notify['queue']
178+
if 'payload' in self.on_exit_notify:
179+
env_args['payload'] = self.on_exit_notify['payload']
180+
181+
if 'env' in self.on_exit_notify:
182+
env_args.update(self.on_exit_notify['env'])
183+
174184
exit_task = CustomTask(
175185
name="exit-handler",
176186
image_name=self.on_exit_notify.get('image', 'workflows-notify-queue'),
177-
workflow_result='{{workflow.status}}',
178-
queue_name=queue,
179-
payload=payload
187+
**env_args
180188
)
181189
spec['onExit'] = 'exit-handler'
182190
spec['templates'].append(

0 commit comments

Comments
 (0)