How to use Prefect with AWS Batch?

Archive
, , ,
1

Docs

Code

Examples

from prefect import flow
from prefect_aws import AwsCredentials
from prefect_aws.batch import batch_submit


@flow
def example_batch_submit_flow():
    aws_credentials = AwsCredentials(
        aws_access_key_id="acccess_key_id",
        aws_secret_access_key="secret_access_key"
    )
    job_id = batch_submit(
        "job_name",
        "job_definition",
        "job_queue",
        aws_credentials
    )
    return job_id

example_batch_submit_flow()

Community contributions