v0.0.7

0.0.7 (2023-03-15)

Bug Fixes

• add better error handling for streaming failutes (8e10580)

v0.0.6

0.0.6 (2023-03-15)

Bug Fixes

• actually use num replicas (4761a1f)

v0.0.5

0.0.5 (2023-03-14)

Bug Fixes

• add ability to output dataclasses (4d9509c)
• add pubsub resource setup (72d16a3)
• add resource setup for bigquery (6a770bd)
• add source for ingesting GCS file changes (6b1a979)
• attempt to gracefully shutdown processors when interupt signal is found (652463d)
• refactor io into seperate sources and sinks (1dccb72)
• support lists of dataclasses and some optimizations (36ef5eb)

v0.0.4

0.0.4 (2023-03-09)

Miscellaneous Chores

• release 0.0.4 (c7f7549)

v0.0.3

0.0.3 (2023-03-03)

Bug Fixes

• add ability to run more than one flow at a time (583d499)
• add usage stats to detect how often users are calling flow.run (1ce6279)
• update API to user a top level flow object (38bd595)
• update description of package (36fb28c)

Miscellaneous Chores

• release 0.0.1 (571bd84)
• release 0.0.3 (efd8b43)

v0.0.1

0.0.1 (2023-02-26)

Miscellaneous Chores

• release 0.0.1 (571bd84)

v0.1.1

0.1.1 (2023-06-09)

Features

• add plan command to buildflow (72f66c0)

Bug Fixes

• actually use num replicas (4761a1f)
• add ability to output dataclasses (4d9509c)
• add ability to run more than one flow at a time (583d499)
• add better autoscaling for streaming use cases (eb07a01)
• add better error handling for streaming failutes (8e10580)
• add metrics (506cd2c)
• add pubsub resource setup (72d16a3)
• add region to SQS source (c81f47a)
• add resource setup for bigquery (6a770bd)
• add some usability improvements (4d8fbbe)
• add source for ingesting GCS file changes (6b1a979)
• add support for SQS as a source (813740e)
• add support to writing to local parquet files (d2b844b)
• add usage stats to detect how often users are calling flow.run (1ce6279)
• attempt to gracefully shutdown processors when interupt signal is found (652463d)
• correctly parse list of dataclasses (ef1bd33)
• correctly parse timestamp fields in dataclasses (a7d27a2)
• drain on sigterm and improve pub/sub backlog (8ad5848)
• error in pubsub walkthrough (669f417)
• finish implementation of streaming autoscaler (3243412)
• improvements to the autoscaller (3b8bb29)
• refactor io into seperate sources and sinks (1dccb72)
• request resource when we hit the max allowed by our current cluster (1377dfd)
• return a single flow results object from flow.run() (e2b2cde)
• set billing project when setting up GCP clients (a11c8f2)
• support lists of dataclasses and some optimizations (36ef5eb)
• update API to user a top level flow object (38bd595)
• update description of package (36fb28c)

Miscellaneous Chores

• release 0.0.1 (571bd84)
• release 0.0.1 (d184bb9)
• release 0.0.3 (efd8b43)
• release 0.0.4 (c7f7549)
• release 0.1.1 (bf71d19)
• release 2.0.0 (58d9129)

v0.1.0

0.1.0 (2023-06-07)

Features

• add plan command to buildflow (72f66c0)

Bug Fixes

• correctly parse list of dataclasses (ef1bd33)
• request resource when we hit the max allowed by our current cluster (1377dfd)