App\Temporal\Workflow\LongWorkflow::run()

Complexity

Conditions	2
Paths	2

Size

Total Lines	30
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	1	Features	0

<?php
    #[\Temporal\Workflow\WorkflowMethod('long_workflow')]
    public function run(string $name, int $count): \Generator
    {
        $activity = Workflow::newActivityStub(
            CommonActivity::class,
            ActivityOptions::new()
                ->withStartToCloseTimeout(6)
        );

        $promises = [];

        foreach (range(1, $count) as $item) {
            $promises[] = $activity->slow($name)
                ->then(
                    function ($result) use ($item) {
                        $this->start = min($this->start, $result['start']);
                        $this->end = max($this->end, $result['end']);
                        $this->done['Task #' . $item] = $result;
                        return $result;
                    }
                );
        }

        $this->status = 'processing';

        $result = yield Promise::all($promises);

        $this->status = 'done';

        return $result;
    }