Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion gloe/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
from gloe.base_transformer import TransformerException
from gloe.async_transformer import AsyncTransformer, MultiArgsAsyncTransformer

__version__ = "0.7.0-rc1"
__version__ = "0.7.0"

__all__ = [
"transformer",
Expand Down
8 changes: 4 additions & 4 deletions gloe/functional.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@


def partial_transformer(
func: Callable[Concatenate[A, P1], S]
func: Callable[Concatenate[A, P1], S],
) -> Callable[P1, Transformer[A, S]]:
"""
This decorator let us create partial transformers, which are transformers that
Expand Down Expand Up @@ -85,7 +85,7 @@ def transform(self, data: A) -> S:


def partial_async_transformer(
func: Callable[Concatenate[A, P1], Awaitable[S]]
func: Callable[Concatenate[A, P1], Awaitable[S]],
) -> Callable[P1, AsyncTransformer[A, S]]:
"""
This decorator enables the creation of partial asynchronous transformers, which are
Expand Down Expand Up @@ -155,7 +155,7 @@ async def transform_async(self, data: A) -> S:

@overload
def transformer(
func: Callable[[A, B, Unpack[Rest]], S]
func: Callable[[A, B, Unpack[Rest]], S],
) -> MultiArgsTransformer[A, B, Unpack[Rest], S]:
pass

Expand Down Expand Up @@ -233,7 +233,7 @@ def transform(self, data=None):

@overload
def async_transformer(
func: Callable[[A, B, Unpack[Rest]], Awaitable[S]]
func: Callable[[A, B, Unpack[Rest]], Awaitable[S]],
) -> MultiArgsAsyncTransformer[A, B, Unpack[Rest], S]:
pass

Expand Down
4 changes: 2 additions & 2 deletions gloe/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,12 +55,12 @@ def transform(self, data: _In) -> _In:

@deprecated("Use `attach` instead.")
def forward_incoming(
inner_transformer: Transformer[_In, _Out]
inner_transformer: Transformer[_In, _Out],
) -> Transformer[_In, Tuple[_Out, _In]]:
return forward[_In]() >> (inner_transformer, forward())


def attach(
inner_transformer: Transformer[_In, _Out]
inner_transformer: Transformer[_In, _Out],
) -> Transformer[_In, Tuple[_Out, _In]]:
return forward[_In]() >> (inner_transformer, forward())
1 change: 1 addition & 0 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ classifiers = [
"Programming Language :: Python :: 3.10",
"Programming Language :: Python :: 3.11",
"Programming Language :: Python :: 3.12",
"Programming Language :: Python :: 3.13",
"License :: OSI Approved :: Apache Software License",
"Operating System :: OS Independent",
]
Expand Down
2 changes: 1 addition & 1 deletion tests/basic/test_transformer_basic.py
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ def test_exhausting_large_flow(self):
max_iters = 320

def ramification(
branch: Transformer[float, float]
branch: Transformer[float, float],
) -> Transformer[float, float]:
return plus1 >> (plus1, branch) >> sum_tuple2

Expand Down