Skip to content

Commit 43b6c1c

Browse files
committed
address pr suggestion
1 parent 3e7ab2f commit 43b6c1c

3 files changed

Lines changed: 4 additions & 5 deletions

File tree

temporalio/bridge/src/client.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -231,6 +231,7 @@ impl ClientRef {
231231
}
232232
"list_workflow_rules" => {
233233
rpc_call!(retry_client, call, list_workflow_rules)
234+
}
234235
"patch_schedule" => {
235236
rpc_call!(retry_client, call, patch_schedule)
236237
}
@@ -324,13 +325,11 @@ impl ClientRef {
324325
"terminate_workflow_execution" => {
325326
rpc_call!(retry_client, call, terminate_workflow_execution)
326327
}
327-
<<<<<<< HEAD
328328
"trigger_workflow_rule" => {
329329
rpc_call!(retry_client, call, trigger_workflow_rule)
330-
=======
330+
}
331331
"unpause_activity" => {
332332
rpc_call!(retry_client, call, unpause_activity)
333-
>>>>>>> 7e4b2d9 (add test for pause/unpause)
334333
}
335334
"update_namespace" => {
336335
rpc_call_on_trait!(retry_client, call, WorkflowService, update_namespace)

temporalio/testing/_activity.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ def __init__(self) -> None:
8080

8181
def cancel(
8282
self,
83-
cancellation_details: temporalio.activity.ActivityCancellationDetails,
83+
cancellation_details: temporalio.activity.ActivityCancellationDetails = temporalio.activity.ActivityCancellationDetails(cancel_requested=True),
8484
) -> None:
8585
"""Cancel the activity.
8686

tests/helpers/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -273,4 +273,4 @@ async def check_unpaused() -> bool:
273273
info = await assert_pending_activity_exists_eventually(handle, activity_id)
274274
return not info.paused
275275

276-
await assert_eventually(check_unpaused)
276+
await assert_eventually(check_unpaused)

0 commit comments

Comments
 (0)