Merge pull request #65 from JonatanMartens/development

v2.2.1

Pipfile

@@ -6,18 +6,19 @@ verify_ssl = true
 [dev-packages]
 autopep8 = "~=1.5.4"
 pylint = "~=2.6.0"
-coverage = "~=5.2.1"
-pytest = "~=6.0.1"
+coverage = "~=5.3"
+pytest = "~=6.1.1"
 pytest-grpc = "~=0.8.0"
-mypy = "~=0.782"
+mypy = "~=0.790"
 coveralls = "~=2.1.2"
-importlib-metadata = "~=1.7.0"
+importlib-metadata = "~=2.0.0"
 pyzeebe = {editable = true, path = "."}
 sphinx = "~=3.2.1"
 sphinx-rtd-theme = "*"
 
 [packages]
-grpcio = "~=1.31.0"
+grpcio = "~=1.32.0"
 protobuf = "~=3.13.0"
 oauthlib = "~=3.1.0"
 requests-oauthlib = "~=1.3.0"
+zeebe-grpc = "~=0.24.3.3"

docs/conf.py

@@ -59,6 +59,6 @@
 # so a file named "default.css" will overwrite the builtin "default.css".
 html_static_path = ['_static']
 
-version = "2.2.0"
+version = "2.2.1"
 
 master_doc = 'index'

docs/worker_taskrouter.rst

@@ -41,6 +41,13 @@ To add the router tasks to the worker we use the :py:func:`include_router` metho
 
     worker.include_router(router)
 
-    ...
+
+Or to add multiple routers at once:
+
+.. code-block:: python
+
+    worker.include_router(router1, router2, router3, ...)
+
+
 
 That's it!

pyzeebe/__init__.py

@@ -1,4 +1,4 @@
-__version__ = "2.2.0"
+__version__ = "2.2.1"
 
 from pyzeebe import exceptions
 from pyzeebe.client.client import ZeebeClient

pyzeebe/grpc_internals/zeebe_adapter_base.py

@@ -2,10 +2,10 @@
 import os
 
 import grpc
+from zeebe_grpc.gateway_pb2_grpc import GatewayStub
 
 from pyzeebe.credentials.base_credentials import BaseCredentials
 from pyzeebe.exceptions import ZeebeBackPressure, ZeebeGatewayUnavailable, ZeebeInternalError
-from pyzeebe.grpc_internals.zeebe_pb2_grpc import GatewayStub
 
 
 class ZeebeAdapterBase(object):

pyzeebe/grpc_internals/zeebe_job_adapter.py

@@ -3,11 +3,11 @@
 from typing import Dict, List, Generator
 
 import grpc
+from zeebe_grpc.gateway_pb2 import ActivateJobsRequest, CompleteJobRequest, CompleteJobResponse, FailJobRequest, \
+    FailJobResponse, ThrowErrorRequest, ThrowErrorResponse
 
 from pyzeebe.exceptions import ActivateJobsRequestInvalid, JobAlreadyDeactivated, JobNotFound
 from pyzeebe.grpc_internals.zeebe_adapter_base import ZeebeAdapterBase
-from pyzeebe.grpc_internals.zeebe_pb2 import ActivateJobsRequest, CompleteJobRequest, CompleteJobResponse, \
-    FailJobRequest, FailJobResponse, ThrowErrorRequest, ThrowErrorResponse
 from pyzeebe.job.job import Job
 
 

pyzeebe/grpc_internals/zeebe_message_adapter.py

@@ -2,10 +2,10 @@
 from typing import Dict
 
 import grpc
+from zeebe_grpc.gateway_pb2 import PublishMessageRequest, PublishMessageResponse
 
 from pyzeebe.exceptions import MessageAlreadyExists
 from pyzeebe.grpc_internals.zeebe_adapter_base import ZeebeAdapterBase
-from pyzeebe.grpc_internals.zeebe_pb2 import PublishMessageRequest, PublishMessageResponse
 
 
 class ZeebeMessageAdapter(ZeebeAdapterBase):