diff --git a/temporalio/client.py b/temporalio/client.py index 3c8e521b..db1e520f 100644 --- a/temporalio/client.py +++ b/temporalio/client.py @@ -1573,7 +1573,7 @@ async def query( """Query the workflow. This will query for :py:attr:`run_id` if present. To use a different - run ID, create a new handle with via + run ID, create a new handle with :py:meth:`Client.get_workflow_handle`. .. warning:: diff --git a/temporalio/service.py b/temporalio/service.py index 7c19b766..01167975 100644 --- a/temporalio/service.py +++ b/temporalio/service.py @@ -184,19 +184,23 @@ def _to_bridge_config(self) -> temporalio.bridge.client.ClientConfig: target_url=target_url, api_key=self.api_key, tls_config=tls_config, - retry_config=self.retry_config._to_bridge_config() - if self.retry_config - else None, - keep_alive_config=self.keep_alive_config._to_bridge_config() - if self.keep_alive_config - else None, + retry_config=( + self.retry_config._to_bridge_config() if self.retry_config else None + ), + keep_alive_config=( + self.keep_alive_config._to_bridge_config() + if self.keep_alive_config + else None + ), metadata=self.rpc_metadata, identity=self.identity, client_name="temporal-python", client_version=__version__, - http_connect_proxy_config=self.http_connect_proxy_config._to_bridge_config() - if self.http_connect_proxy_config - else None, + http_connect_proxy_config=( + self.http_connect_proxy_config._to_bridge_config() + if self.http_connect_proxy_config + else None + ), ) diff --git a/tests/worker/test_workflow.py b/tests/worker/test_workflow.py index 9f007a22..74958cf9 100644 --- a/tests/worker/test_workflow.py +++ b/tests/worker/test_workflow.py @@ -3902,7 +3902,7 @@ def matches_metric_line( return False # Must have labels (don't escape for this test) for k, v in at_least_labels.items(): - if not f'{k}="{v}"' in line: + if f'{k}="{v}"' not in line: return False return line.endswith(f" {value}") @@ -4856,7 +4856,7 @@ async def assert_scenario( update_scenario: Optional[FailureTypesScenario] = None, ) -> None: logging.debug( - f"Asserting scenario %s", + "Asserting scenario %s", { "workflow": workflow, "expect_task_fail": expect_task_fail,