prefect-aws 0.3.2

Version 0.3.2

on Python PyPI

Major Features

• Local parallelism with DaskExecutor - #151, #186
• Resource throttling based on tags - #158, #186
• Task.map for mapping tasks - #186
• Added AirFlow utility for importing Airflow DAGs as Prefect Flows - #232

Minor Features

• Use Netlify to deploy docs - #156
• Add changelog - #153
• Add ShellTask - #150
• Base Task class can now be run as a dummy task - #191
• New return_failed keyword to flow.run() for returning failed tasks - #205
• some minor changes to flow.visualize() for visualizing mapped tasks and coloring nodes by state - #202
• Added new flow.replace() method for swapping out tasks within flows - #230
• Add debug kwarg to DaskExecutor for optionally silencing dask logs - #209
• Update BokehRunner for visualizing mapped tasks - #220
• Env var configuration settings are typed - #204
• Implement map functionality for the LocalExecutor - #233

Fixes

• Fix issue with Versioneer not picking up git tags - #146
• DotDicts can have non-string keys - #193
• Fix unexpected behavior in assigning tags using contextmanagers - #190
• Fix bug in initialization of Flows with only edges - #225
• Remove "bottleneck" when creating pipelines of mapped tasks - #224

Breaking Changes

• Runner refactor - #221
• Cleaned up signatures of TaskRunner methods - #171
• Locally, Python 3.4 users can not run the more advanced parallel executors (DaskExecutor) #186