Paco Ibañez
05/10/2022, 8:31 PMPaco 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
Paco Ibañez
05/10/2022, 8:44 PM