Skip to content

Commit 021bff7

Browse files
committed
Fix phpdoc
1 parent e1cdca0 commit 021bff7

40 files changed

+48
-113
lines changed

src/Activity/ActivityContextInterface.php

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,23 +21,20 @@ interface ActivityContextInterface
2121
* Returns information about current activity execution.
2222
*
2323
* @see Activity::getInfo()
24-
*
2524
*/
2625
public function getInfo(): ActivityInfo;
2726

2827
/**
2928
* Returns activity execution input arguments.
3029
*
3130
* @see Activity::getInput()
32-
*
3331
*/
3432
public function getInput(): ValuesInterface;
3533

3634
/**
3735
* Check if the heartbeat's first argument has been passed.
3836
*
3937
* @see Activity::hasHeartbeatDetails()
40-
*
4138
*/
4239
public function hasHeartbeatDetails(): bool;
4340

@@ -55,7 +52,6 @@ public function getHeartbeatDetails($type = null);
5552
* Marks the activity as incomplete for asynchronous completion.
5653
*
5754
* @see Activity::doNotCompleteOnReturn()
58-
*
5955
*/
6056
public function doNotCompleteOnReturn(): void;
6157

src/Activity/ActivityInfo.php

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,6 @@ final class ActivityInfo
3737
* A correlation token that can be used to complete the activity through `complete` method.
3838
*
3939
* @see ActivityCompletionClientInterface::complete()
40-
*
4140
*/
4241
#[Marshal(name: 'TaskToken')]
4342
public string $taskToken;
@@ -56,14 +55,12 @@ final class ActivityInfo
5655
* activity through `complete` method.
5756
*
5857
* @see ActivityCompletionClientInterface::complete()
59-
*
6058
*/
6159
#[Marshal(name: 'ActivityID')]
6260
public string $id;
6361

6462
/**
6563
* Type (name) of the activity.
66-
*
6764
*/
6865
#[Marshal(name: 'ActivityType', type: ObjectType::class, of: ActivityType::class)]
6966
public ActivityType $type;
@@ -73,36 +70,31 @@ final class ActivityInfo
7370

7471
/**
7572
* Maximum time between heartbeats. 0 means no heartbeat needed.
76-
*
7773
*/
7874
#[Marshal(name: 'HeartbeatTimeout', type: DateIntervalType::class)]
7975
public \DateInterval $heartbeatTimeout;
8076

8177
/**
8278
* Time of activity scheduled by a workflow
83-
*
8479
*/
8580
#[Marshal(name: 'ScheduledTime', type: DateTimeType::class)]
8681
public \DateTimeInterface $scheduledTime;
8782

8883
/**
8984
* Time of activity start
90-
*
9185
*/
9286
#[Marshal(name: 'StartedTime', type: DateTimeType::class)]
9387
public \DateTimeInterface $startedTime;
9488

9589
/**
9690
* Time of activity timeout
97-
*
9891
*/
9992
#[Marshal(name: 'Deadline', type: DateTimeType::class)]
10093
public \DateTimeInterface $deadline;
10194

10295
/**
10396
* Attempt starts from 1, and increased by 1 for every retry if
10497
* retry policy is specified.
105-
*
10698
*/
10799
#[Marshal(name: 'Attempt')]
108100
public int $attempt = 1;

src/Client/Common/RpcRetryOptions.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,6 @@ public function withCongestionInitialInterval($interval): self
7373
*
7474
* @param null|float $coefficient Maximum amount of jitter.
7575
* Default will be used if set to {@see null}.
76-
*
7776
*/
7877
#[Pure]
7978
public function withMaximumJitterCoefficient(?float $coefficient): self

src/Client/GRPC/BaseClient.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,6 @@ public function close(): void
165165

166166
/**
167167
* @param null|Pipeline<GrpcClientInterceptor, object> $pipeline
168-
*
169168
*/
170169
final public function withInterceptorPipeline(?Pipeline $pipeline): static
171170
{

src/Client/Update/UpdateHandle.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@ public function getId(): string
5656

5757
/**
5858
* Check there is a cached accepted result or failure for this update request.
59-
*
6059
*/
6160
public function hasResult(): bool
6261
{

src/Client/WorkflowClient.php

Lines changed: 37 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -94,17 +94,16 @@ public static function create(
9494
return new self($serviceClient, $options, $converter, $interceptorProvider);
9595
}
9696

97+
/**
98+
* @inheritDoc
99+
*/
97100
public function getServiceClient(): ServiceClientInterface
98101
{
99102
return $this->client;
100103
}
101104

102105
/**
103-
* Starts workflow in async mode. Returns WorkflowRun object which can be used to wait for the execution result.
104-
* WorkflowRun objects created by typed workflow stubs will attempt to type the execution result as well.
105-
*
106-
* @param object|WorkflowStubInterface $workflow
107-
* @param mixed ...$args
106+
* @inheritDoc
108107
*/
109108
public function start($workflow, ...$args): WorkflowRunInterface
110109
{
@@ -148,6 +147,9 @@ public function start($workflow, ...$args): WorkflowRunInterface
148147
);
149148
}
150149

150+
/**
151+
* @inheritDoc
152+
*/
151153
public function signalWithStart(
152154
$workflow,
153155
string $signal,
@@ -206,6 +208,9 @@ public function signalWithStart(
206208
);
207209
}
208210

211+
/**
212+
* @inheritDoc
213+
*/
209214
#[Deprecated(replacement: '%class%->signalWithStart(%parametersList%)')]
210215
public function startWithSignal(
211216
$workflow,
@@ -216,6 +221,9 @@ public function startWithSignal(
216221
return $this->signalWithStart($workflow, $signal, $signalArgs, $startArgs);
217222
}
218223

224+
/**
225+
* @inheritDoc
226+
*/
219227
public function updateWithStart(
220228
$workflow,
221229
string|UpdateOptions $update,
@@ -250,6 +258,9 @@ public function updateWithStart(
250258
: $handle;
251259
}
252260

261+
/**
262+
* @inheritDoc
263+
*/
253264
public function newWorkflowStub(
254265
string $class,
255266
?WorkflowOptions $options = null,
@@ -263,6 +274,9 @@ public function newWorkflowStub(
263274
);
264275
}
265276

277+
/**
278+
* @inheritDoc
279+
*/
266280
public function newUntypedWorkflowStub(
267281
string $workflowType,
268282
?WorkflowOptions $options = null,
@@ -279,6 +293,9 @@ public function newUntypedWorkflowStub(
279293
);
280294
}
281295

296+
/**
297+
* @inheritDoc
298+
*/
282299
public function newRunningWorkflowStub(string $class, string $workflowID, ?string $runID = null): object
283300
{
284301
$workflow = $this->reader->fromClass($class);
@@ -290,6 +307,9 @@ public function newRunningWorkflowStub(string $class, string $workflowID, ?strin
290307
);
291308
}
292309

310+
/**
311+
* @inheritDoc
312+
*/
293313
public function newUntypedRunningWorkflowStub(
294314
string $workflowID,
295315
?string $runID = null,
@@ -307,11 +327,17 @@ public function newUntypedRunningWorkflowStub(
307327
return $untyped;
308328
}
309329

330+
/**
331+
* @inheritDoc
332+
*/
310333
public function newActivityCompletionClient(): ActivityCompletionClientInterface
311334
{
312335
return new ActivityCompletionClient($this->client, $this->clientOptions, $this->converter);
313336
}
314337

338+
/**
339+
* @inheritDoc
340+
*/
315341
public function listWorkflowExecutions(
316342
string $query,
317343
?string $namespace = null,
@@ -348,6 +374,9 @@ public function listWorkflowExecutions(
348374
return Paginator::createFromGenerator($loader($request), $counter);
349375
}
350376

377+
/**
378+
* @inheritDoc
379+
*/
351380
public function countWorkflowExecutions(
352381
string $query,
353382
?string $namespace = null,
@@ -363,6 +392,9 @@ public function countWorkflowExecutions(
363392
);
364393
}
365394

395+
/**
396+
* @inheritDoc
397+
*/
366398
public function getWorkflowHistory(
367399
WorkflowExecution $execution,
368400
?string $namespace = null,

src/Client/WorkflowClientInterface.php

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,10 +29,13 @@ interface WorkflowClientInterface extends ClientContextInterface
2929
public function getServiceClient(): ServiceClientInterface;
3030

3131
/**
32-
* Starts untyped and typed workflow stubs in async mode.
32+
* Starts workflow in async mode.
33+
*
34+
* Returns WorkflowRun object which can be used to wait for the execution result.
35+
* WorkflowRun objects created by typed workflow stubs will attempt to type the execution result as well.
3336
*
3437
* @param WorkflowStubInterface|object $workflow
35-
* @param mixed $args
38+
* @param mixed ...$args
3639
*/
3740
public function start($workflow, ...$args): WorkflowRunInterface;
3841

@@ -111,7 +114,6 @@ public function newWorkflowStub(
111114
*
112115
* IMPORTANT! Stub is per workflow instance. So new stub should be created
113116
* for each new one.
114-
*
115117
*/
116118
public function newUntypedWorkflowStub(
117119
string $workflowType,
@@ -133,7 +135,6 @@ public function newRunningWorkflowStub(
133135

134136
/**
135137
* Returns untyped workflow stub associated with running workflow.
136-
*
137138
*/
138139
public function newUntypedRunningWorkflowStub(
139140
string $workflowID,
@@ -148,7 +149,6 @@ public function newUntypedRunningWorkflowStub(
148149
* Only relevant for activity implementations that called {@see ActivityContext::doNotCompleteOnReturn()}.
149150
*
150151
* @see ActivityCompletionClient
151-
*
152152
*/
153153
public function newActivityCompletionClient(): ActivityCompletionClientInterface;
154154

@@ -203,7 +203,6 @@ public function countWorkflowExecutions(
203203
* Available values are {@see HistoryEventFilterType} constants.
204204
* @param int<0, max> $pageSize Size of the pages to be requested. It affects internal queries only. Use it if you
205205
* want to load limited number of events from the history.
206-
*
207206
*/
208207
public function getWorkflowHistory(
209208
WorkflowExecution $execution,

src/Client/WorkflowStubInterface.php

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@ public function getWorkflowType(): ?string;
4040
/**
4141
* Returns associated workflow options. Empty for running workflows. Workflow options are immutable and can
4242
* not be changed after the workflow was created.
43-
*
4443
*/
4544
public function getOptions(): ?WorkflowOptions;
4645

@@ -53,13 +52,11 @@ public function getExecution(): WorkflowExecution;
5352

5453
/**
5554
* Check if workflow was started and has associated execution.
56-
*
5755
*/
5856
public function hasExecution(): bool;
5957

6058
/**
6159
* Attaches running workflow context to the workflow stub.
62-
*
6360
*/
6461
public function setExecution(WorkflowExecution $execution): void;
6562

@@ -122,7 +119,6 @@ public function getUpdateHandle(string $updateId, mixed $resultType = null): Upd
122119
* Cancellation cancels {@see CancellationScopeInterface} that wraps the
123120
* main workflow method. Note that workflow can take long time to get
124121
* canceled or even completely ignore the cancellation request.
125-
*
126122
*/
127123
public function cancel(): void;
128124

@@ -131,7 +127,6 @@ public function cancel(): void;
131127
*
132128
* Termination is a hard stop of a workflow execution which doesn't give
133129
* workflow code any chance to perform cleanup.
134-
*
135130
*/
136131
public function terminate(string $reason, array $details = []): void;
137132
}

src/Common/CronSchedule.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ final class CronSchedule implements \Stringable
4949
* │ │ │ │ │
5050
* * * * * *
5151
* ```
52-
*
5352
*/
5453
#[Immutable]
5554
public string $interval;

src/DataConverter/EncodedValues.php

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ public static function sliceValues(
7575
* Decode promise response upon returning it to the domain layer.
7676
*
7777
* @param string|\ReflectionClass|\ReflectionType|Type|null $type
78-
*
7978
*/
8079
public static function decodePromise(PromiseInterface $promise, $type = null): PromiseInterface
8180
{
@@ -101,7 +100,6 @@ public static function fromValues(array $values, ?DataConverterInterface $dataCo
101100

102101
/**
103102
* @param TPayloadsCollection $payloads
104-
*
105103
*/
106104
public static function fromPayloadCollection(
107105
\Traversable $payloads,

0 commit comments

Comments
 (0)