# We instantiate a step functions workflow and orchestrate the glue jobs.
with StepfunctionsWorkflow(datajob_stack=datajob_stack, name="workflow", notification="some-email...") as sfn:
task1 >> task2
if we define a notification we create an SNS to add to the pipeline
it accepts an email address as string or a list of email addresses
it notifies in case of failure or in case of success