File tree Expand file tree Collapse file tree 2 files changed +4
-6
lines changed
Expand file tree Collapse file tree 2 files changed +4
-6
lines changed Original file line number Diff line number Diff line change 1919)
2020from hatchet_sdk .config import ClientConfig
2121from hatchet_sdk .connection import new_conn
22- from hatchet_sdk .contracts .events_pb2 import BulkPushEventRequest
23- from hatchet_sdk .contracts .events_pb2 import Event as EventProto
24- from hatchet_sdk .contracts .events_pb2 import Events as EventsProto
2522from hatchet_sdk .contracts .events_pb2 import (
23+ BulkPushEventRequest ,
2624 PushEventRequest ,
2725 PutLogRequest ,
2826 PutStreamEventRequest ,
2927)
28+ from hatchet_sdk .contracts .events_pb2 import Event as EventProto
29+ from hatchet_sdk .contracts .events_pb2 import Events as EventsProto
3030from hatchet_sdk .contracts .events_pb2_grpc import EventsServiceStub
3131from hatchet_sdk .logger import logger
3232from hatchet_sdk .metadata import get_metadata
Original file line number Diff line number Diff line change @@ -584,9 +584,7 @@ async def handle_cancel_action(self, action: Action) -> None:
584584 )
585585 else :
586586 # Task completed quickly - log success and exit
587- logger .info (
588- f"Cancellation: task { action .action_id } completed"
589- )
587+ logger .info (f"Cancellation: task { action .action_id } completed" )
590588 finally :
591589 self .cleanup_run_id (key )
592590
You can’t perform that action at this time.
0 commit comments