Skip to content

Latest commit

 

History

History
105 lines (64 loc) · 2.8 KB

File metadata and controls

105 lines (64 loc) · 2.8 KB

Changelog

All notable changes to this project will be documented in this file.

The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.

0.5.0 - 2024-07-21

Added

  • Added support for named arguments.

Changed

  • Dataclasses require now named arguments instead of unnamed placeholders.

0.4.1 - 2024-04-01

Added

  • Added support for Python 3.8 and 3.11.

0.4.0 - 2024-01-11

Added

  • ReadFromPostgres transform for reading from the database in batches.

0.3.2 - 2023-01-16

Changed

  • Do not sleep after non-retryable errors. There is no sense in waiting for something.

0.3.1 - 2023-01-12

Changed

  • Improve retry logging to include an error message.

0.3.0 - 2022-11-26

Added

  • Allow customizing maximum retry delay in WriteToPostgres.

0.2.3 - 2022-11-24

Fixed

  • Fix error type check in RetryRowOnTransientErrorStrategy.

0.2.2 - 2022-11-22

Fixed

  • Resolved "TypeError: Cannot convert GlobalWindow to apache_beam.utils.windowed_value._IntervalWindowBase" for non-global windows.

0.2.1 - 2022-11-21

Fixed

  • Fixed missing argument in sleep log.
  • Fixed establishing connection per bundle without closing, which resulted in connection leakage.

0.2.0 - 2022-11-21

Added

  • RetryRowStrategy ABC class to provide an interface for various retry logics used in WriteToPostgres transform.
  • AlwaysRetryRowStrategy and RetryRowOnTransientErrorStrategy retry strategies.

Changed

  • Renamed ReadFromPostgres to ReadAllFromPostgres, so the name better reflects how the transform works.
  • WriteToPostgres returns a PCollection of tuples with the failed element and error to allow the graceful handling of errors.

0.1.0 - 2022-11-14

Added

  • ReadFromPostgres transform for reading from the database.
  • WriteToPostgres transform for writing to the database.