File tree Expand file tree Collapse file tree 1 file changed +1
-4
lines changed
tests/Acceptance/Harness/Update Expand file tree Collapse file tree 1 file changed +1
-4
lines changed Original file line number Diff line number Diff line change 1212use Temporal \Activity \ActivityMethod ;
1313use Temporal \Activity \ActivityOptions ;
1414use Temporal \Client \WorkflowStubInterface ;
15- use Temporal \Exception \Failure \ApplicationFailure ;
1615use Temporal \Tests \Acceptance \App \Attribute \Stub ;
1716use Temporal \Tests \Acceptance \App \Runtime \RRStarter ;
1817use Temporal \Tests \Acceptance \App \TestCase ;
@@ -32,7 +31,6 @@ public static function check(
3231 ContainerInterface $ c ,
3332 RRStarter $ runner ,
3433 ): void {
35- $ c ->get (StorageInterface::class)->set (KV_ACTIVITY_BLOCKED , true );
3634 $ handle = $ stub ->startUpdate ('do_activities ' );
3735
3836 # Wait for the activity to start.
@@ -95,9 +93,8 @@ public function blocks(): string
9593 $ this ->kv ->set (KV_ACTIVITY_STARTED , true );
9694
9795 do {
98- $ blocked = $ this ->kv ->get (KV_ACTIVITY_BLOCKED );
96+ $ blocked = $ this ->kv ->get (KV_ACTIVITY_BLOCKED , true );
9997
100- \is_bool ($ blocked ) or throw new ApplicationFailure ('KV BLOCKED key not set ' , 'KvNotSet ' , true );
10198 if (!$ blocked ) {
10299 break ;
103100 }
You can’t perform that action at this time.
0 commit comments