Matej Války
02/23/2021, 12:50 AMCameron Gallivan
02/23/2021, 6:12 AMclient = boto3.client('batch')
response = client.submit_job(jobDefinition=context.solid_config['job_definition'],
jobName=context.solid_config['job_name'],
jobQueue=context.solid_config['job_queue'],
containerOverrides={'vcpus': solid_config['vcpus'],
'memory': solid_config['memory']})
From there you can use a botocore waiter to hold the pipeline up until the batch job is completed or use a dagster sensor to trigger another pipeline to start when the output appears on s3Matej Války
02/23/2021, 12:39 PMCameron Gallivan
02/23/2021, 4:55 PM