Remove some prints. Add simple test that confirms start_batch_operation is wired up through bridge and core

Author: VegetarianOrc

scripts/gen_bridge_client.py

@@ -61,8 +61,6 @@ def service_name(s):
             )
         )
 
-    print(f"successfully generated client at {output_file}")
-
 
 def generate_python_service(service_descriptor: ServiceDescriptor) -> str:
     service_template = Template("""
@@ -158,12 +156,8 @@ def generate_rust_client_impl(
     with open(output_file, "w") as f:
         f.write(impl_template.substitute(service_calls="\n".join(service_calls)))
 
-    print(f"successfully generated client at {output_file}")
-
 
 def generate_rust_service_call(service_descriptor: ServiceDescriptor) -> str:
-    print(f"generating rpc call wrapper for {service_descriptor.full_name}")
-
     call_template = Template("""
 fn call_${service_name}<'p>(
     &self,

tests/test_client.py

@@ -33,7 +33,9 @@
     WorkflowTaskFailedCause,
 )
 from temporalio.api.history.v1 import History
-from temporalio.api.workflowservice.v1 import GetSystemInfoRequest
+from temporalio.api.workflowservice.v1 import GetSystemInfoRequest, request_response_pb2
+from temporalio.api.batch.v1 import message_pb2
+from temporalio.api.enums.v1 import reset_pb2
 from temporalio.client import (
     BuildIdOpAddNewCompatible,
     BuildIdOpAddNewDefault,
@@ -1552,3 +1554,22 @@ async def get_schedule_result() -> Tuple[int, Optional[str]]:
         )
 
         await handle.delete()
+
+
+async def test_workflow_client_start_batch_operation(client: Client):
+    # This test is used to ensure that the start_batch_operation is wired through
+    # the layers of python -> bridge python -> bridge rust -> core
+    # https://github.com/temporalio/sdk-python/issues/927
+
+    request = request_response_pb2.StartBatchOperationRequest(
+        namespace="default",
+        visibility_query='WorkflowType="test_workflow"',
+        job_id=f"batch-reset-{int(datetime.now().timestamp())}",
+        reason="test",
+        reset_operation=message_pb2.BatchOperationReset(
+            reset_type=reset_pb2.RESET_TYPE_LAST_WORKFLOW_TASK
+        ),
+    )
+
+    response = await client.workflow_service.start_batch_operation(request)
+    assert response is not None