Skip to content

Commit de712df

Browse files
authored
Adjust default values (#60)
Adjust default workflow/activity options.
1 parent a2b9062 commit de712df

31 files changed

+69
-65
lines changed

src/Client/WorkflowOptions.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ final class WorkflowOptions extends Options
8282
* The timeout for processing workflow task from the time the worker pulled
8383
* this task. If a workflow task is lost, it is retried after this timeout.
8484
*
85-
* Optional: defaulted to 10 secs.
85+
* Optional: defaulted to no limit
8686
*/
8787
#[Marshal(name: 'WorkflowTaskTimeout', type: DateIntervalType::class)]
8888
public \DateInterval $workflowTaskTimeout;
@@ -135,9 +135,9 @@ final class WorkflowOptions extends Options
135135
public function __construct()
136136
{
137137
$this->workflowId = Uuid::v4();
138-
$this->workflowExecutionTimeout = CarbonInterval::years(10);
139-
$this->workflowRunTimeout = CarbonInterval::years(10);
140-
$this->workflowTaskTimeout = CarbonInterval::seconds(10);
138+
$this->workflowExecutionTimeout = CarbonInterval::seconds(0);
139+
$this->workflowRunTimeout = CarbonInterval::seconds(0);
140+
$this->workflowTaskTimeout = CarbonInterval::seconds(0);
141141
$this->retryOptions = new RetryOptions();
142142

143143
parent::__construct();

src/Workflow/ChildWorkflowOptions.php

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ final class ChildWorkflowOptions extends Options
7272
* The end to end timeout for the child workflow execution including
7373
* retries and continue as new.
7474
*
75-
* Optional: defaults to 10 years
75+
* Optional: defaults is no limit
7676
*/
7777
#[Marshal(name: 'WorkflowExecutionTimeout', type: DateIntervalType::class)]
7878
public \DateInterval $workflowExecutionTimeout;
@@ -91,7 +91,7 @@ final class ChildWorkflowOptions extends Options
9191
/**
9292
* The workflow task timeout for the child workflow.
9393
*
94-
* Optional: default is 10s if this is not provided (or if 0 is provided).
94+
* Optional: default is no limit
9595
*/
9696
#[Marshal(name: 'WorkflowTaskTimeout', type: DateIntervalType::class)]
9797
public \DateInterval $workflowTaskTimeout;
@@ -164,9 +164,9 @@ final class ChildWorkflowOptions extends Options
164164
*/
165165
public function __construct()
166166
{
167-
$this->workflowExecutionTimeout = CarbonInterval::years(10);
168-
$this->workflowRunTimeout = CarbonInterval::years(10);
169-
$this->workflowTaskTimeout = CarbonInterval::seconds(10);
167+
$this->workflowExecutionTimeout = CarbonInterval::seconds(0);
168+
$this->workflowRunTimeout = CarbonInterval::seconds(0);
169+
$this->workflowTaskTimeout = CarbonInterval::seconds(0);
170170
$this->retryOptions = new RetryOptions();
171171

172172
parent::__construct();

src/Workflow/ContinueAsNewOptions.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ final class ContinueAsNewOptions
4848
/**
4949
* The workflow task timeout for the child workflow.
5050
*
51-
* Optional: default is 10s if this is not provided (or if 0 is provided).
51+
* Optional: default is no limit
5252
*/
5353
#[Marshal(name: 'WorkflowTaskTimeout', type: DateIntervalType::class)]
5454
public \DateInterval $workflowTaskTimeout;
@@ -58,8 +58,8 @@ final class ContinueAsNewOptions
5858
*/
5959
public function __construct()
6060
{
61-
$this->workflowRunTimeout = CarbonInterval::years(10);
62-
$this->workflowTaskTimeout = CarbonInterval::seconds(10);
61+
$this->workflowRunTimeout = CarbonInterval::seconds(0);
62+
$this->workflowTaskTimeout = CarbonInterval::seconds(0);
6363
}
6464

6565
/**

tests/Fixtures/data/Test_ActivityStubWorkflow.log

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
2021/01/12 15:25:13 DEBUG [{"id":1,"command":"StartWorkflow","options":{"info":{"WorkflowExecution":{"ID":"abd6d54b-e24e-4790-a7f9-37056176783e","RunID":"3088cdc7-bcae-4f49-940c-8bf30f7f4e18"},"WorkflowType":{"Name":"ActivityStubWorkflow"},"TaskQueueName":"default","WorkflowExecutionTimeout":315360000000000000,"WorkflowRunTimeout":315360000000000000,"WorkflowTaskTimeout":10000000000,"Namespace":"default","Attempt":1,"CronSchedule":"","ContinuedExecutionRunID":"","ParentWorkflowNamespace":"","ParentWorkflowExecution":null,"Memo":null,"SearchAttributes":null,"BinaryChecksum":"8646d54f9f6b22f407d6d22254eea9f5"}},"payloads":"CicKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SDSJoZWxsbyB3b3JsZCI="}] {"taskQueue":"default","tickTime":"2021-01-12T15:25:13.3983204Z"}
1+
2021/01/12 15:25:13 DEBUG [{"id":1,"command":"StartWorkflow","options":{"info":{"WorkflowExecution":{"ID":"abd6d54b-e24e-4790-a7f9-37056176783e","RunID":"3088cdc7-bcae-4f49-940c-8bf30f7f4e18"},"WorkflowType":{"Name":"ActivityStubWorkflow"},"TaskQueueName":"default","WorkflowExecutionTimeout":315360000000000000,"WorkflowRunTimeout":315360000000000000,"WorkflowTaskTimeout":0,"Namespace":"default","Attempt":1,"CronSchedule":"","ContinuedExecutionRunID":"","ParentWorkflowNamespace":"","ParentWorkflowExecution":null,"Memo":null,"SearchAttributes":null,"BinaryChecksum":"8646d54f9f6b22f407d6d22254eea9f5"}},"payloads":"CicKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SDSJoZWxsbyB3b3JsZCI="}] {"taskQueue":"default","tickTime":"2021-01-12T15:25:13.3983204Z"}
22
2021/01/12 15:25:13 DEBUG [{"id":9001,"command":"ExecuteActivity","options":{"name":"SimpleActivity.echo","options":{"TaskQueueName":"default","ScheduleToCloseTimeout":0,"ScheduleToStartTimeout":0,"StartToCloseTimeout":5000000000,"HeartbeatTimeout":0,"WaitForCancellation":false,"ActivityID":"","RetryPolicy":{"initial_interval":null,"backoff_coefficient":2,"maximum_interval":null,"maximum_attempts":1,"non_retryable_error_types":[]}}},"payloads":"CicKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SDSJoZWxsbyB3b3JsZCI="},{"id":1,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"}] {"receive": true}
33
2021/01/12 15:25:13 DEBUG [{"id":9001,"payloads":"CicKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SDSJIRUxMTyBXT1JMRCI="}] {"taskQueue":"default","tickTime":"2021-01-12T15:25:13.4849445Z"}
44
2021/01/12 15:25:13 DEBUG [{"id":9002,"command":"ExecuteActivity","options":{"name":"SimpleActivity.echo","options":{"TaskQueueName":"default","ScheduleToCloseTimeout":0,"ScheduleToStartTimeout":0,"StartToCloseTimeout":1000000000,"HeartbeatTimeout":0,"WaitForCancellation":false,"ActivityID":"","RetryPolicy":{"initial_interval":null,"backoff_coefficient":2,"maximum_interval":null,"maximum_attempts":1,"non_retryable_error_types":[]}}},"payloads":"CiMKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SCSJ1bnR5cGVkIg=="}] {"receive": true}

tests/Fixtures/data/Test_BatchedSignal.log

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
2021/01/27 06:51:20 DEBUG [{"id":7,"command":"StartWorkflow","options":{"info":{"WorkflowExecution":{"ID":"b4881b9a-e0a8-4433-b330-27457af9d2c0","RunID":"d453e8be-c071-40fa-b342-9bf1197b6b2a"},"WorkflowType":{"Name":"Signal.greet"},"TaskQueueName":"default","WorkflowExecutionTimeout":60000000000,"WorkflowRunTimeout":60000000000,"WorkflowTaskTimeout":10000000000,"Namespace":"default","Attempt":1,"CronSchedule":"","ContinuedExecutionRunID":"","ParentWorkflowNamespace":"","ParentWorkflowExecution":null,"Memo":null,"SearchAttributes":null,"BinaryChecksum":"9f3a48a8f2d7bb5fae539d23df402a74"}}}] {"taskQueue":"default","tickTime":"2021-01-27T06:51:20Z"}
1+
2021/01/27 06:51:20 DEBUG [{"id":7,"command":"StartWorkflow","options":{"info":{"WorkflowExecution":{"ID":"b4881b9a-e0a8-4433-b330-27457af9d2c0","RunID":"d453e8be-c071-40fa-b342-9bf1197b6b2a"},"WorkflowType":{"Name":"Signal.greet"},"TaskQueueName":"default","WorkflowExecutionTimeout":60000000000,"WorkflowRunTimeout":60000000000,"WorkflowTaskTimeout":0,"Namespace":"default","Attempt":1,"CronSchedule":"","ContinuedExecutionRunID":"","ParentWorkflowNamespace":"","ParentWorkflowExecution":null,"Memo":null,"SearchAttributes":null,"BinaryChecksum":"9f3a48a8f2d7bb5fae539d23df402a74"}}}] {"taskQueue":"default","tickTime":"2021-01-27T06:51:20Z"}
22
2021/01/27 06:51:20 DEBUG [{"id":7,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"}] {"receive": true}
33
2021/01/27 06:51:20 DEBUG [{"id":8,"command":"InvokeSignal","options":{"runId":"d453e8be-c071-40fa-b342-9bf1197b6b2a","name":"addName"},"payloads":"CiIKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SCCJBbnRvbnki"}] {"taskQueue":"default","tickTime":"2021-01-27T06:51:20Z"}
44
2021/01/27 06:51:20 DEBUG [{"id":8,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"}] {"receive": true}
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
2021/01/27 06:53:20 DEBUG [{"id":1,"command":"StartWorkflow","options":{"info":{"WorkflowExecution":{"ID":"388c01c0-9e5d-4634-9444-2fc13e4b68e5","RunID":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966"},"WorkflowType":{"Name":"Signal.greet"},"TaskQueueName":"default","WorkflowExecutionTimeout":60000000000,"WorkflowRunTimeout":60000000000,"WorkflowTaskTimeout":10000000000,"Namespace":"default","Attempt":1,"CronSchedule":"","ContinuedExecutionRunID":"","ParentWorkflowNamespace":"","ParentWorkflowExecution":null,"Memo":null,"SearchAttributes":null,"BinaryChecksum":"9f3a48a8f2d7bb5fae539d23df402a74"}}},{"id":2,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"addName"},"payloads":"CiIKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SCCJBbnRvbnki"},{"id":3,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"addName"},"payloads":"CiAKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SBiJKb2huIg=="},{"id":4,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"addName"},"payloads":"Ch8KFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SBSJCb2Ii"},{"id":5,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"exit"}}] {"taskQueue":"default","tickTime":"2021-01-27T06:53:20Z"}
1+
2021/01/27 06:53:20 DEBUG [{"id":1,"command":"StartWorkflow","options":{"info":{"WorkflowExecution":{"ID":"388c01c0-9e5d-4634-9444-2fc13e4b68e5","RunID":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966"},"WorkflowType":{"Name":"Signal.greet"},"TaskQueueName":"default","WorkflowExecutionTimeout":60000000000,"WorkflowRunTimeout":60000000000,"WorkflowTaskTimeout":0,"Namespace":"default","Attempt":1,"CronSchedule":"","ContinuedExecutionRunID":"","ParentWorkflowNamespace":"","ParentWorkflowExecution":null,"Memo":null,"SearchAttributes":null,"BinaryChecksum":"9f3a48a8f2d7bb5fae539d23df402a74"}}},{"id":2,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"addName"},"payloads":"CiIKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SCCJBbnRvbnki"},{"id":3,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"addName"},"payloads":"CiAKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SBiJKb2huIg=="},{"id":4,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"addName"},"payloads":"Ch8KFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SBSJCb2Ii"},{"id":5,"command":"InvokeSignal","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966","name":"exit"}}] {"taskQueue":"default","tickTime":"2021-01-27T06:53:20Z"}
22
2021/01/27 06:53:20 DEBUG [{"id":1,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"},{"id":2,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"},{"id":3,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"},{"id":4,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"},{"id":5,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"},{"id":9001,"command":"CompleteWorkflow","options":{},"payloads":"CkkKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SL1siSGVsbG8sIEFudG9ueSEiLCJIZWxsbywgSm9obiEiLCJIZWxsbywgQm9iISJd"}] {"receive": true}
33
2021/01/27 06:53:20 DEBUG [{"id":9001,"payloads":"CiUKFgoIZW5jb2RpbmcSCmpzb24vcGxhaW4SCyJjb21wbGV0ZWQi"},{"id":6,"command":"DestroyWorkflow","options":{"runId":"98b6d77e-fa56-4c8a-a341-a8c7e53f6966"}}] {"taskQueue":"default","tickTime":"2021-01-27T06:53:20Z","replay":true}
44
2021/01/27 06:53:20 DEBUG [{"id":6,"payloads":"ChkKFwoIZW5jb2RpbmcSC2JpbmFyeS9udWxs"}] {"receive": true}

0 commit comments

Comments
 (0)