Skip to content

Commit

Permalink
chore: temporarily add pre check attr to publisher
Browse files Browse the repository at this point in the history
  • Loading branch information
z3z1ma committed Jul 21, 2024
1 parent a0533b1 commit db188fd
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions src/cdf/nextgen/model.py
Original file line number Diff line number Diff line change
Expand Up @@ -85,8 +85,12 @@ def __class_getitem__(cls, _):
DataPipeline = Component[t.Optional["LoadInfo"]]
"""A data pipeline which loads data from a source to a destination."""

DataPublisher = Component[t.Any] # TODO: track intervals
"""A data publisher which pushes data to an operational system."""

class DataPublisher(Component[t.Any]):
"""A data publisher which pushes data to an operational system."""

pre_check: t.Optional[injector.Dependency[bool]] = None


Operation = Component[int]
"""A generic callable that returns an exit code."""
Expand Down

0 comments on commit db188fd

Please sign in to comment.