Paco Ibañez
05/10/2022, 8:31 PMdef create_flow_run(flow: dict):
payload = dict(
name = 'my_run',
flow_id = flow['id'],
flow_runner = dict(
type = 'docker',
config = dict(
image = 'my-prefect-orion',
image_pull_policy = 'IF_NOT_PRESENT',
networks = ['prefect'],
env = {
"USE_SSL": False,
"AWS_ACCESS_KEY_ID": "*****",
"AWS_SECRET_ACCESS_KEY": "******",
"ENDPOINT_URL": '<http://minio:9000>',
}
)
),
state = dict(type='SCHEDULED'),
parameters = dict(),
)
resp = <http://session.post|session.post>(f'{ORION_SERVER_URL}/api/flow_runs', json=payload)
Kevin Kho
05/10/2022, 8:41 PMPaco Ibañez
05/10/2022, 8:44 PM