prefect-aws 0.3.3

Version 0.3.3

on Python PyPI

Major Features

• Refactor FlowRunner and TaskRunner into a modular Runner pipelines - #260, #267
• Add configurable state_handlers for FlowRunners, Flows, TaskRunners, and Tasks - #264, #267
• Add gmail and slack notification state handlers w/ tutorial - #274, #294

Minor Features

• Add a new method flow.get_tasks() for easily filtering flow tasks by attribute - #242
• Add new JinjaTemplateTask for easily rendering jinja templates - #200
• Add new PAUSE signal for halting task execution - #246
• Add new Paused state corresponding to PAUSE signal, and new pause_task utility - #251
• Add ability to timeout task execution for all executors except DaskExecutor(processes=True) - #240
• Add explicit unit test to check Black formatting (Python 3.6+) - #261
• Add ability to set local secrets in user config file - #231, #274
• Add is_skipped() and is_scheduled() methods for State objects - #266, #278
• Adds now() as a default start_time for Scheduled states - #278
• Signal classes now pass arguments to underlying State objects - #279
• Run counts are tracked via Retrying states - #281

Fixes

• Flow consistently raises if passed a parameter that doesn't exist - #149

Breaking Changes

• Renamed scheduled_time -> start_time in Scheduled state objects - #278
• TaskRunner.check_for_retry no longer checks for Retry states without start_time set - #278
• Swapped the position of result and message attributes in State initializations, and started storing caught exceptions as results - #283