ran formatter

Author: GSmithApps

custom_metric/worker.py

@@ -16,15 +16,13 @@
 
 
 class SimpleWorkerInterceptor(Interceptor):
-
     def intercept_activity(
         self, next: ActivityInboundInterceptor
     ) -> ActivityInboundInterceptor:
         return CustomScheduleToStartInterceptor(next)
 
 
 class CustomScheduleToStartInterceptor(ActivityInboundInterceptor):
-
     async def execute_activity(self, input: ExecuteActivityInput):
 
         schedule_to_start = (

custom_metric/workflow.py

@@ -9,7 +9,6 @@
 
 @workflow.defn
 class StartTwoActivitiesWorkflow:
-
     @workflow.run
     async def run(self):
         # Request two concurrent activities with only one task slot so

tests/custom_metric/workflow_test.py

@@ -12,7 +12,6 @@
 
 
 async def test_custom_metric_workflow(client: Client):
-
     @activity.defn(name="print_message")
     async def print_message_mock():
         global activity_counter