Format fix

Author: Sushisource

worker_versioning/activities.py

@@ -1,10 +1,12 @@
 from dataclasses import dataclass
+
 from temporalio import activity
 
 
 @dataclass
 class IncompatibleActivityInput:
     """Input for the incompatible activity."""
+
     called_by: str
     more_data: str
 

worker_versioning/app.py

@@ -3,9 +3,10 @@
 import asyncio
 import logging
 import uuid
+
 from temporalio.client import Client
 
-from worker_versioning.constants import TASK_QUEUE, DEPLOYMENT_NAME
+from worker_versioning.constants import DEPLOYMENT_NAME, TASK_QUEUE
 
 logging.basicConfig(level=logging.INFO)
 

worker_versioning/constants.py

@@ -4,4 +4,4 @@
 TASK_QUEUE = "worker-versioning"
 
 # Deployment name
-DEPLOYMENT_NAME = "my-deployment"
+DEPLOYMENT_NAME = "my-deployment"

worker_versioning/workerv1.py

@@ -2,13 +2,14 @@
 
 import asyncio
 import logging
+
 from temporalio.client import Client
-from temporalio.worker import Worker, WorkerDeploymentConfig
 from temporalio.common import WorkerDeploymentVersion
+from temporalio.worker import Worker, WorkerDeploymentConfig
 
-from worker_versioning.constants import TASK_QUEUE, DEPLOYMENT_NAME
-from worker_versioning.workflows import AutoUpgradingWorkflowV1, PinnedWorkflowV1
 from worker_versioning.activities import some_activity, some_incompatible_activity
+from worker_versioning.constants import DEPLOYMENT_NAME, TASK_QUEUE
+from worker_versioning.workflows import AutoUpgradingWorkflowV1, PinnedWorkflowV1
 
 logging.basicConfig(level=logging.INFO)
 

worker_versioning/workerv1_1.py

@@ -2,13 +2,14 @@
 
 import asyncio
 import logging
+
 from temporalio.client import Client
-from temporalio.worker import Worker, WorkerDeploymentConfig
 from temporalio.common import WorkerDeploymentVersion
+from temporalio.worker import Worker, WorkerDeploymentConfig
 
-from worker_versioning.constants import TASK_QUEUE, DEPLOYMENT_NAME
-from worker_versioning.workflows import AutoUpgradingWorkflowV1b, PinnedWorkflowV1
 from worker_versioning.activities import some_activity, some_incompatible_activity
+from worker_versioning.constants import DEPLOYMENT_NAME, TASK_QUEUE
+from worker_versioning.workflows import AutoUpgradingWorkflowV1b, PinnedWorkflowV1
 
 logging.basicConfig(level=logging.INFO)
 

worker_versioning/workerv2.py

@@ -2,13 +2,14 @@
 
 import asyncio
 import logging
+
 from temporalio.client import Client
-from temporalio.worker import Worker, WorkerDeploymentConfig
 from temporalio.common import WorkerDeploymentVersion
+from temporalio.worker import Worker, WorkerDeploymentConfig
 
-from worker_versioning.constants import TASK_QUEUE, DEPLOYMENT_NAME
-from worker_versioning.workflows import AutoUpgradingWorkflowV1b, PinnedWorkflowV2
 from worker_versioning.activities import some_activity, some_incompatible_activity
+from worker_versioning.constants import DEPLOYMENT_NAME, TASK_QUEUE
+from worker_versioning.workflows import AutoUpgradingWorkflowV1b, PinnedWorkflowV2
 
 logging.basicConfig(level=logging.INFO)
 

worker_versioning/workflows.py

@@ -1,13 +1,14 @@
 """Workflow definitions for the worker versioning sample."""
 
 from datetime import timedelta
-from temporalio import workflow, common
+
+from temporalio import common, workflow
 
 with workflow.unsafe.imports_passed_through():
     from worker_versioning.activities import (
+        IncompatibleActivityInput,
         some_activity,
         some_incompatible_activity,
-        IncompatibleActivityInput,
     )