Fix imports using isort

examples/client.py

@@ -1,4 +1,9 @@
-from pyzeebe import ZeebeClient, create_camunda_cloud_channel, create_insecure_channel, create_secure_channel
+from pyzeebe import (
+    ZeebeClient,
+    create_camunda_cloud_channel,
+    create_insecure_channel,
+    create_secure_channel,
+)
 
 # Create a zeebe client without credentials
 grpc_channel = create_insecure_channel(hostname="localhost", port=26500)

examples/worker.py

@@ -1,7 +1,13 @@
 import asyncio
 from typing import Dict
 
-from pyzeebe import Job, ZeebeWorker, create_camunda_cloud_channel, create_insecure_channel, create_secure_channel
+from pyzeebe import (
+    Job,
+    ZeebeWorker,
+    create_camunda_cloud_channel,
+    create_insecure_channel,
+    create_secure_channel,
+)
 from pyzeebe.errors import BusinessError
 
 

pyzeebe/channel/camunda_cloud_channel.py

@@ -6,7 +6,10 @@
 from requests_oauthlib import OAuth2Session
 
 from pyzeebe.channel.channel_options import get_channel_options
-from pyzeebe.errors import InvalidCamundaCloudCredentialsError, InvalidOAuthCredentialsError
+from pyzeebe.errors import (
+    InvalidCamundaCloudCredentialsError,
+    InvalidOAuthCredentialsError,
+)
 
 
 def create_camunda_cloud_channel(

pyzeebe/grpc_internals/zeebe_adapter_base.py

@@ -5,7 +5,11 @@
 import grpc
 from zeebe_grpc.gateway_pb2_grpc import GatewayStub
 
-from pyzeebe.errors import ZeebeBackPressureError, ZeebeGatewayUnavailableError, ZeebeInternalError
+from pyzeebe.errors import (
+    ZeebeBackPressureError,
+    ZeebeGatewayUnavailableError,
+    ZeebeInternalError,
+)
 
 logger = logging.getLogger(__name__)
 

pyzeebe/grpc_internals/zeebe_job_adapter.py

@@ -13,7 +13,11 @@
     ThrowErrorResponse,
 )
 
-from pyzeebe.errors import ActivateJobsRequestInvalidError, JobAlreadyDeactivatedError, JobNotFoundError
+from pyzeebe.errors import (
+    ActivateJobsRequestInvalidError,
+    JobAlreadyDeactivatedError,
+    JobNotFoundError,
+)
 from pyzeebe.grpc_internals.zeebe_adapter_base import ZeebeAdapterBase
 from pyzeebe.job.job import Job
 

pyzeebe/worker/task_router.py

@@ -1,7 +1,12 @@
 import logging
 from typing import Callable, List, Optional, Tuple
 
-from pyzeebe.errors import BusinessError, DuplicateTaskTypeError, NoVariableNameGivenError, TaskNotFoundError
+from pyzeebe.errors import (
+    BusinessError,
+    DuplicateTaskTypeError,
+    NoVariableNameGivenError,
+    TaskNotFoundError,
+)
 from pyzeebe.function_tools import parameter_tools
 from pyzeebe.job.job import Job
 from pyzeebe.task import task_builder

tests/unit/channel/camunda_cloud_channel_test.py

@@ -7,7 +7,10 @@
 from requests import HTTPError
 
 from pyzeebe import create_camunda_cloud_channel
-from pyzeebe.errors import InvalidCamundaCloudCredentialsError, InvalidOAuthCredentialsError
+from pyzeebe.errors import (
+    InvalidCamundaCloudCredentialsError,
+    InvalidOAuthCredentialsError,
+)
 
 
 @pytest.fixture

tests/unit/grpc_internals/zeebe_adapter_base_test.py

@@ -2,7 +2,11 @@
 import pytest
 from mock import AsyncMock
 
-from pyzeebe.errors import ZeebeBackPressureError, ZeebeGatewayUnavailableError, ZeebeInternalError
+from pyzeebe.errors import (
+    ZeebeBackPressureError,
+    ZeebeGatewayUnavailableError,
+    ZeebeInternalError,
+)
 from pyzeebe.grpc_internals.zeebe_adapter_base import ZeebeAdapterBase
 
 

tests/unit/grpc_internals/zeebe_job_adapter_test.py

@@ -2,9 +2,17 @@
 from uuid import uuid4
 
 import pytest
-from zeebe_grpc.gateway_pb2 import CompleteJobResponse, FailJobResponse, ThrowErrorResponse
-
-from pyzeebe.errors import ActivateJobsRequestInvalidError, JobAlreadyDeactivatedError, JobNotFoundError
+from zeebe_grpc.gateway_pb2 import (
+    CompleteJobResponse,
+    FailJobResponse,
+    ThrowErrorResponse,
+)
+
+from pyzeebe.errors import (
+    ActivateJobsRequestInvalidError,
+    JobAlreadyDeactivatedError,
+    JobNotFoundError,
+)
 from pyzeebe.grpc_internals.zeebe_job_adapter import ZeebeJobAdapter
 from pyzeebe.job.job import Job
 from pyzeebe.task.task import Task