Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(sinks): add a sink decorator #7

Merged
merged 1 commit into from
Apr 14, 2024
Merged

Conversation

kennedykori
Copy link
Contributor

Add sghi.etl.commons.sinks.sink, a decorator that marks a callable as a Sink. The decorated callable MUST accept at least one argument but have at MOST one required argument (the processed data to drain/consume).

Add `sghi.etl.commons.sinks.sink`, a decorator that marks a callable as
a `Sink`. The decorated callable *MUST* accept at least one argument but
have at *MOST* one required argument (the processed data to drain/consume).
@kennedykori kennedykori self-assigned this Apr 14, 2024
@kennedykori kennedykori merged commit 6a89c85 into develop Apr 14, 2024
3 checks passed
@kennedykori kennedykori deleted the feat-add-a-sink-decorator branch April 14, 2024 21:29
kennedykori added a commit that referenced this pull request Apr 16, 2024
## [1.0.0-rc.1](...v1.0.0-rc.1) (2024-04-16)

### Dependency Updates

* **deps:** upgrade project dependencies ([#2](#2)) ([6bee92c](6bee92c))

### Features

* **processors:** add a `ProcessorPipe` ([#10](#10)) ([82a006e](82a006e))
* **processors:** add a NOOP `Processor` ([#3](#3)) ([ecdf529](ecdf529))
* **processors:** add a processor decorator ([#4](#4)) ([9f3b039](9f3b039))
* **sinks:** add a `NullSink` ([#9](#9)) ([2794f6a](2794f6a))
* **sinks:** add a sink decorator ([#7](#7)) ([6a89c85](6a89c85))
* **sources:** add a source decorator ([#5](#5)) ([b42328e](b42328e))
* **utils:** add result gatherers ([#1](#1)) ([7c4e34f](7c4e34f))
* **worflow_def:** add a `SimpleWorkflowDefinition` ([#11](#11)) ([ce1a9b0](ce1a9b0))

### Refactors

* **processors:** mark `processors._ProcessorOfCallable` as final ([#6](#6)) ([9e5d6c6](9e5d6c6))
* **sinks:** rename `sinks._SourceOfCallable` class ([#8](#8)) ([e6f08e5](e6f08e5))
@kennedykori
Copy link
Contributor Author

🎉 This PR is included in version 1.0.0-rc.1 🎉

The release is available on:

Your semantic-release bot 📦🚀

kennedykori added a commit that referenced this pull request Apr 16, 2024
## [1.0.0](...v1.0.0) (2024-04-16)

### Dependency Updates

* **deps:** upgrade project dependencies ([#2](#2)) ([6bee92c](6bee92c))

### Features

* **processors:** add a `ProcessorPipe` ([#10](#10)) ([82a006e](82a006e))
* **processors:** add a NOOP `Processor` ([#3](#3)) ([ecdf529](ecdf529))
* **processors:** add a processor decorator ([#4](#4)) ([9f3b039](9f3b039))
* **sinks:** add a `NullSink` ([#9](#9)) ([2794f6a](2794f6a))
* **sinks:** add a sink decorator ([#7](#7)) ([6a89c85](6a89c85))
* **sources:** add a source decorator ([#5](#5)) ([b42328e](b42328e))
* **utils:** add result gatherers ([#1](#1)) ([7c4e34f](7c4e34f))
* **worflow_def:** add a `SimpleWorkflowDefinition` ([#11](#11)) ([ce1a9b0](ce1a9b0))

### Refactors

* **processors:** mark `processors._ProcessorOfCallable` as final ([#6](#6)) ([9e5d6c6](9e5d6c6))
* **sinks:** rename `sinks._SourceOfCallable` class ([#8](#8)) ([e6f08e5](e6f08e5))
@kennedykori
Copy link
Contributor Author

🎉 This PR is included in version 1.0.0 🎉

The release is available on:

Your semantic-release bot 📦🚀

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant