From b859458e996aee51bec84deb9fa4a758b36dac4f Mon Sep 17 00:00:00 2001 From: gabriel ruttner Date: Thu, 25 Jul 2024 18:08:32 -0400 Subject: [PATCH] release: a2 --- hatchet_sdk/clients/dispatcher/action_listener.py | 2 +- hatchet_sdk/worker/runner/runner.py | 4 +--- pyproject.toml | 2 +- 3 files changed, 3 insertions(+), 5 deletions(-) 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"