worker method optional page size

basis-company · Sep 12, 2023 · e18b0f1 · e18b0f1
1 parent d256802
commit e18b0f1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sharded_queue/__init__.py b/sharded_queue/__init__.py
@@ -211,7 +211,7 @@ class Worker:
     coordinator: Coordinator
     queue: Queue
 
-    def page_size(self, limit: int | None = None) -> int:
+    def page_size(self, limit: Optional[int] = None) -> int:
         if limit is None:
             return settings.worker_batch_size