Skip to content

Commit 11f01f8

Browse files
committed
Move code in util package to _internal
There was just a single function `cancel_and_await` that was only for internal use. Signed-off-by: Sahas Subramanian <[email protected]>
1 parent 7c29a61 commit 11f01f8

File tree

5 files changed

+3
-8
lines changed

5 files changed

+3
-8
lines changed

src/frequenz/sdk/actor/_resampling.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,7 @@
1111

1212
from frequenz.channels import Receiver, Sender
1313

14-
from frequenz.sdk.util.asyncio import cancel_and_await
15-
14+
from .._internal.asyncio import cancel_and_await
1615
from ..timeseries import Sample
1716
from ..timeseries._resampling import Resampler, ResamplerConfig, ResamplingError
1817
from ._channel_registry import ChannelRegistry

src/frequenz/sdk/timeseries/_resampling.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
from frequenz.channels.util import Timer
1919

20-
from ..util.asyncio import cancel_and_await
20+
from .._internal.asyncio import cancel_and_await
2121
from . import Sample
2222

2323
_logger = logging.getLogger(__name__)

src/frequenz/sdk/timeseries/logical_meter/_formula_engine.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
from frequenz.channels import Broadcast, Receiver
1818
from frequenz.channels._broadcast import Receiver as BroadcastReceiver
1919

20-
from ...util.asyncio import cancel_and_await
20+
from ..._internal.asyncio import cancel_and_await
2121
from .. import Sample
2222
from ._formula_steps import (
2323
Adder,

src/frequenz/sdk/util/__init__.py

Lines changed: 0 additions & 4 deletions
This file was deleted.

0 commit comments

Comments
 (0)