Trevor Kramer
with case(is_rapids(input), True): export_result = ExportsTask()(secret_task, 'somekey', stack) with case(is_rapids(input), False): export_result = ExportsTask()(secret_task, 'anotherkey', stack) MyTask()(input, export_result['training_job_queue'], export_result['training_job_definition'], PipelineArtifactsBucketTask()(secret_task, stack))
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.