Kwarg

Author: tconley1428

temporalio/client.py

@@ -262,7 +262,7 @@ def _init_from_config(self, config: ClientConfig):
         for interceptor in reversed(list(self._config["interceptors"])):
             self._impl = interceptor.intercept_client(self._impl)
 
-    def config(self, active_config: bool = False) -> ClientConfig:
+    def config(self, *, active_config: bool = False) -> ClientConfig:
         """Config, as a dictionary, used to create this client.
 
         Args:
@@ -4295,7 +4295,7 @@ async def _to_proto(
             await _apply_headers(
                 self.headers,
                 action.start_workflow.header.fields,
-                client.config(True)["header_codec_behavior"]
+                client.config(active_config=True)["header_codec_behavior"]
                 == HeaderCodecBehavior.CODEC
                 and not self._from_raw,
                 client.data_converter.payload_codec,
@@ -6923,7 +6923,7 @@ async def _apply_headers(
         await _apply_headers(
             source,
             dest,
-            self._client.config(True)["header_codec_behavior"]
+            self._client.config(active_config=True)["header_codec_behavior"]
             == HeaderCodecBehavior.CODEC,
             self._client.data_converter.payload_codec,
         )

temporalio/worker/_replayer.py

@@ -92,7 +92,7 @@ def __init__(
         if not self._config["workflows"]:
             raise ValueError("At least one workflow must be specified")
 
-    def config(self, active_config: bool = False) -> ReplayerConfig:
+    def config(self, *, active_config: bool = False) -> ReplayerConfig:
         """Config, as a dictionary, used to create this replayer.
 
         Args:

temporalio/worker/_worker.py

@@ -409,7 +409,7 @@ def _init_from_config(self, client: temporalio.client.Client, config: WorkerConf
             )
 
         # Prepend applicable client interceptors to the given ones
-        client_config = config["client"].config(True)
+        client_config = config["client"].config(active_config=True)
         interceptors_from_client = cast(
             List[Interceptor],
             [i for i in client_config["interceptors"] if isinstance(i, Interceptor)],
@@ -623,7 +623,7 @@ def check_activity(activity):
             ),
         )
 
-    def config(self, active_config: bool = False) -> WorkerConfig:
+    def config(self, *, active_config: bool = False) -> WorkerConfig:
         """Config, as a dictionary, used to create this worker.
 
         Args:

tests/test_plugins.py

@@ -150,7 +150,7 @@ async def test_worker_plugin_basic_config(client: Client) -> None:
         activities=[never_run_activity],
         plugins=[MyWorkerPlugin()],
     )
-    task_queue = worker.config(True).get("task_queue")
+    task_queue = worker.config(active_config=True).get("task_queue")
     assert task_queue is not None and task_queue.startswith("replaced_queue")
 
     # Test client plugin propagation to worker plugins
@@ -160,7 +160,7 @@ async def test_worker_plugin_basic_config(client: Client) -> None:
     worker = Worker(
         client, task_queue="queue" + str(uuid.uuid4()), activities=[never_run_activity]
     )
-    task_queue = worker.config(True).get("task_queue")
+    task_queue = worker.config(active_config=True).get("task_queue")
     assert task_queue is not None and task_queue.startswith("combined")
 
     # Test both. Client propagated plugins are called first, so the worker plugin overrides in this case
@@ -170,7 +170,7 @@ async def test_worker_plugin_basic_config(client: Client) -> None:
         activities=[never_run_activity],
         plugins=[MyWorkerPlugin()],
     )
-    task_queue = worker.config(True).get("task_queue")
+    task_queue = worker.config(active_config=True).get("task_queue")
     assert task_queue is not None and task_queue.startswith("replaced_queue")
 
 
@@ -202,7 +202,8 @@ async def test_worker_sandbox_restrictions(client: Client) -> None:
     assert (
         "my_module"
         in cast(
-            SandboxedWorkflowRunner, worker.config(True).get("workflow_runner")
+            SandboxedWorkflowRunner,
+            worker.config(active_config=True).get("workflow_runner"),
         ).restrictions.passthrough_modules
     )
 
@@ -276,8 +277,11 @@ async def test_replay(client: Client) -> None:
         )
         await handle.result()
     replayer = Replayer(workflows=[], plugins=[plugin])
-    assert len(replayer.config(True).get("workflows") or []) == 1
-    assert replayer.config(True).get("data_converter") == pydantic_data_converter
+    assert len(replayer.config(active_config=True).get("workflows") or []) == 1
+    assert (
+        replayer.config(active_config=True).get("data_converter")
+        == pydantic_data_converter
+    )
 
     await replayer.replay_workflow(await handle.fetch_history())
 
@@ -303,19 +307,28 @@ async def test_simple_plugins(client: Client) -> None:
         plugins=[plugin],
     )
     # On a sequence, a value is appended
-    assert worker.config(True).get("workflows") == [HelloWorkflow, HelloWorkflow2]
+    assert worker.config(active_config=True).get("workflows") == [
+        HelloWorkflow,
+        HelloWorkflow2,
+    ]
 
     # Test with plugin registered in client
     worker = Worker(
         new_client,
         task_queue="queue" + str(uuid.uuid4()),
         activities=[never_run_activity],
     )
-    assert worker.config(True).get("workflows") == [HelloWorkflow2]
+    assert worker.config(active_config=True).get("workflows") == [HelloWorkflow2]
 
     replayer = Replayer(workflows=[HelloWorkflow], plugins=[plugin])
-    assert replayer.config(True).get("data_converter") == pydantic_data_converter
-    assert replayer.config(True).get("workflows") == [HelloWorkflow, HelloWorkflow2]
+    assert (
+        replayer.config(active_config=True).get("data_converter")
+        == pydantic_data_converter
+    )
+    assert replayer.config(active_config=True).get("workflows") == [
+        HelloWorkflow,
+        HelloWorkflow2,
+    ]
 
 
 async def test_simple_plugins_callables(client: Client) -> None:
@@ -350,7 +363,7 @@ def converter(old: Optional[DataConverter]):
         activities=[never_run_activity],
         plugins=[plugin],
     )
-    assert worker.config(True).get("workflows") == []
+    assert worker.config(active_config=True).get("workflows") == []
 
 
 class MediumPlugin(SimplePlugin):
@@ -371,5 +384,5 @@ async def test_medium_plugin(client: Client) -> None:
         plugins=[plugin],
         workflows=[HelloWorkflow],
     )
-    task_queue = worker.config(True).get("task_queue")
+    task_queue = worker.config(active_config=True).get("task_queue")
     assert task_queue is not None and task_queue.startswith("override")