Xinchi He
11/12/2021, 8:31 PMKevin Kho
Xinchi He
11/12/2021, 9:05 PMKevin Kho
with Flow("Docker sidecar example") as flow:
# Create and start the docker container
container_id = create_container(image)
started = start_container(container_id=container_id)
# Once the docker container has started, wait until it's completed and get the status
status_code = wait_on_container(container_id=container_id, upstream_tasks=[started])
# Once the status code has been retrieved, retrieve the logs
logs = get_logs(container_id=container_id, upstream_tasks=[status_code])
and then you just need to know the syntax to chain upstream dependencies
with Flow(...) as flow:
a = task1()
b = task2(x, upstream_tasks=[a])
Xinchi He
11/12/2021, 9:13 PMflow-container
stuff is a placeholder, and each time a dockerPull
will overwrite that placeholder if I understand it correctly. We'll give it a shot, thanks!!Kevin Kho
flow_container1
and flow_container2
will be separate containers from the original flow containerXinchi He
11/12/2021, 9:18 PMKevin Kho
Xinchi He
11/12/2021, 9:22 PMBring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by