diff --git a/hatchet_sdk/clients/dispatcher/action_listener.py b/hatchet_sdk/clients/dispatcher/action_listener.py index 8dac22f0..1dbc3e29 100644 --- a/hatchet_sdk/clients/dispatcher/action_listener.py +++ b/hatchet_sdk/clients/dispatcher/action_listener.py @@ -21,10 +21,10 @@ WorkerUnsubscribeRequest, ) from hatchet_sdk.contracts.dispatcher_pb2_grpc import DispatcherStub +from hatchet_sdk.logger import logger from hatchet_sdk.utils.backoff import exp_backoff_sleep from ...loader import ClientConfig -from hatchet_sdk.logger import logger from ...metadata import get_metadata from ..events import proto_timestamp_now diff --git a/hatchet_sdk/worker/runner/runner.py b/hatchet_sdk/worker/runner/runner.py index 64541a0d..42f451d9 100644 --- a/hatchet_sdk/worker/runner/runner.py +++ b/hatchet_sdk/worker/runner/runner.py @@ -153,9 +153,7 @@ def __init__( def run(self, action: Action): match action.action_type: case ActionType.START_STEP_RUN: - logger.info( - f"run: start step: {action.action_id}/{action.step_run_id}" - ) + logger.info(f"run: start step: {action.action_id}/{action.step_run_id}") asyncio.create_task(self.handle_start_step_run(action)) case ActionType.CANCEL_STEP_RUN: logger.info( diff --git a/pyproject.toml b/pyproject.toml index 5469c288..0a6ff682 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "hatchet-sdk" -version = "0.31.6-a1" +version = "0.31.6-a2" description = "" authors = ["Alexander Belanger "] readme = "README.md"