Steve Hiehn
09/06/2023, 1:33 AMflyte_task_a = self.client.fetch_task(name=task_name)
flyte_task_b = self.client.fetch_task(name=task_name)
flyte_task_c = self.client.fetch_task(name=task_name)
workflow = Workflow(name=workflow_name)
workflow.add_entity(flyte_task_a)
workflow.add_entity(flyte_task_b)
workflow.add_entity(flyte_task_c)
THIS IS WHAT I WANT TO DO:
flyte_task_a = self.client.fetch_task(name=task_name)
flyte_task_b = self.client.fetch_task(name=task_name)
flyte_task_c = self.client.fetch_task(name=task_name)
flyte_task_a.add_arbitraty_data(custom_uuid)
flyte_task_b.add_arbitraty_data(custom_uuid)
flyte_task_c.add_arbitraty_data(custom_uuid)
workflow = Workflow(name=workflow_name)
workflow.add_entity(flyte_task_a)
workflow.add_entity(flyte_task_b)
workflow.add_entity(flyte_task_c)
Samhita Alla
Steve Hiehn
09/06/2023, 1:56 PMSamhita Alla
Steve Hiehn
09/07/2023, 2:23 PM