Make nexus slot supplier optional for backwards compatibility

Author: dandavison

temporalio/worker/_tuning.py

@@ -391,12 +391,14 @@ def create_resource_based(
     @staticmethod
     def create_fixed(
         *,
-        workflow_slots: Optional[int],
-        activity_slots: Optional[int],
-        local_activity_slots: Optional[int],
-        nexus_slots: Optional[int],
+        workflow_slots: Optional[int] = None,
+        activity_slots: Optional[int] = None,
+        local_activity_slots: Optional[int] = None,
+        nexus_slots: Optional[int] = None,
     ) -> WorkerTuner:
-        """Create a fixed-size tuner with the provided number of slots. Any unspecified slots will default to 100."""
+        """Create a fixed-size tuner with the provided number of slots.
+
+        Any unspecified slot numbers will default to 100."""
         return _CompositeTuner(
             FixedSizeSlotSupplier(workflow_slots if workflow_slots else 100),
             FixedSizeSlotSupplier(activity_slots if activity_slots else 100),
@@ -409,17 +411,19 @@ def create_fixed(
     @staticmethod
     def create_composite(
         *,
-        workflow_supplier: SlotSupplier,
-        activity_supplier: SlotSupplier,
-        local_activity_supplier: SlotSupplier,
-        nexus_supplier: SlotSupplier,
+        workflow_supplier: Optional[SlotSupplier] = None,
+        activity_supplier: Optional[SlotSupplier] = None,
+        local_activity_supplier: Optional[SlotSupplier] = None,
+        nexus_supplier: Optional[SlotSupplier] = None,
     ) -> WorkerTuner:
-        """Create a tuner composed of the provided slot suppliers."""
+        """Create a tuner composed of the provided slot suppliers.
+
+        Any unspecified slot suppliers will default to :py:class:`FixedSizeSlotSupplier` with a capacity of 100."""
         return _CompositeTuner(
-            workflow_supplier,
-            activity_supplier,
-            local_activity_supplier,
-            nexus_supplier,
+            workflow_supplier or FixedSizeSlotSupplier(100),
+            activity_supplier or FixedSizeSlotSupplier(100),
+            local_activity_supplier or FixedSizeSlotSupplier(100),
+            nexus_supplier or FixedSizeSlotSupplier(100),
         )
 
     @abstractmethod

tests/worker/test_worker.py

@@ -577,10 +577,7 @@ def release_slot(self, ctx: SlotReleaseContext) -> None:
     ss = ThrowingSlotSupplier()
 
     tuner = WorkerTuner.create_composite(
-        workflow_supplier=ss,
-        activity_supplier=ss,
-        local_activity_supplier=ss,
-        nexus_supplier=ss,
+        workflow_supplier=ss, activity_supplier=ss, local_activity_supplier=ss
     )
     async with new_worker(
         client,
@@ -616,10 +613,7 @@ def release_slot(self, ctx: SlotReleaseContext) -> None:
     ss = BlockingSlotSupplier()
 
     tuner = WorkerTuner.create_composite(
-        workflow_supplier=ss,
-        activity_supplier=ss,
-        local_activity_supplier=ss,
-        nexus_supplier=ss,
+        workflow_supplier=ss, activity_supplier=ss, local_activity_supplier=ss
     )
     async with new_worker(
         client,