Merge pull request #3 from adjust/fix-complain

fix(complain): fix lint

Author: saber-solooki

Diff for: .github/workflows/ci.yml

@@ -138,11 +138,7 @@ jobs:
       - name: build
         run: python -m build
 
-      - name: Upload package to PyPI
-        uses: pypa/gh-action-pypi-publish@release/v1
-
-      - name: publish docs
-        if: '!fromJSON(steps.check-version.outputs.IS_PRERELEASE)'
-        run: make publish-docs
-        env:
-          NETLIFY: ${{ secrets.netlify_token }}
+      - name: Upload wheel to PyPI
+        if: env.PYPI_SSH_KEY
+        run: |
+          scp dist/*.whl automate-infra-1.adjust.com:~/pypi/wheels

Diff for: arq/connections.py

@@ -89,7 +89,6 @@ def __repr__(self) -> str:
 enqueued_jobs = 0
 
 
-
 class ArqRedis(BaseRedis):
     """
     Thin subclass of ``redis.asyncio.Redis`` which adds :func:`arq.connections.enqueue_job`.
@@ -130,7 +129,7 @@ async def enqueue_job(
         _defer_by: Union[None, int, float, timedelta] = None,
         _expires: Union[None, int, float, timedelta] = None,
         _job_try: Optional[int] = None,
-        distribution: str = None,  # example 5:2
+        distribution: Optional[str] = None,  # example 5:2
         **kwargs: Any,
     ) -> Optional[Job]:
         """
@@ -195,8 +194,8 @@ async def enqueue_job(
                 return None
         return Job(job_id, redis=self, _queue_name=_queue_name, _deserializer=self.job_deserializer)
 
-    def _get_queue_index(self, distribution) -> int:
-        ratios = list(map(lambda x: int(x), distribution.split(':')))
+    def _get_queue_index(self, distribution: Optional[str]) -> int:
+        ratios = list(map(lambda x: int(x), distribution.split(':')))  # type: ignore[union-attr]
         ratios_sum = sum(ratios)
         up_to_ratio = ratios[0]
         queue_index = 0

Diff for: arq/worker.py

@@ -81,7 +81,7 @@ def func(
 
     if isinstance(coroutine, str):
         name = name or coroutine
-        coroutine_: 'WorkerCoroutine' = import_string(coroutine)
+        coroutine_: WorkerCoroutine = import_string(coroutine)
     else:
         coroutine_ = coroutine
 
@@ -187,7 +187,7 @@ def __init__(
         self,
         functions: Sequence[Union[Function, 'WorkerCoroutine']] = (),
         *,
-        distribution_index: int = None,
+        distribution_index: Optional[int] = None,
         queue_name: Optional[str] = default_queue_name,
         cron_jobs: Optional[Sequence[CronJob]] = None,
         redis_settings: Optional[RedisSettings] = None,