Keith Veleba
01/31/2022, 5:53 PMKevin Kho
Keith Veleba
01/31/2022, 5:56 PMKevin Kho
Keith Veleba
01/31/2022, 5:57 PMKevin Kho
Keith Veleba
01/31/2022, 5:58 PMbatch_submit = BatchSubmit()
batch_observer = AWSClientWait(client="batch", waier_name="JobCompleted")
with Flow(FLOW_NAME, storage=STORAGE) as flow:
hello_world_job = batch_submit.run(
job_name="prefect-tcf-hello",
job_definition="tcf-sample",
job_queue="tcf-tokenization",
# batch_kwargs=boto_args,
)
batch_observer()
flow.register(project_name=PROJECT_NAME)
Kevin Kho
Keith Veleba
01/31/2022, 6:09 PMbatch_submit = BatchSubmit(
job_name="prefect-tcf-hello",
job_definition="tcf-sample",
job_queue="tcf-tokenization",)
batch_observer = AWSClientWait(client="batch", waiter_name="JobCompleted")
with Flow(FLOW_NAME, storage=STORAGE) as flow:
hello_world_job = batch_submit()
batch_observer()
flow.register(project_name=PROJECT_NAME)
Kevin Kho
Keith Veleba
01/31/2022, 6:13 PM