Skip to content

Commit bb6e359

Browse files
committed
Changed namespace, added php-etl/console-state and php-etl/pipeline-console-runtime into dependencies
1 parent 4836c07 commit bb6e359

File tree

4 files changed

+119
-10
lines changed

4 files changed

+119
-10
lines changed

composer.json

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,18 @@
1919
"php": "^8.0",
2020
"symfony/console": "^5.2",
2121
"php-etl/pipeline-contracts": "^0.3.0",
22-
"php-etl/pipeline": "^0.4.0"
22+
"php-etl/pipeline": "^0.4.0",
23+
"php-etl/console-state": "^0.1.0",
24+
"php-etl/pipeline-console-runtime": "^0.1.0"
2325
},
2426
"autoload": {
2527
"psr-4": {
26-
"Kiboko\\Component\\Runtime\\WorkflowConsoleRuntime\\": "src/"
28+
"Kiboko\\Component\\Runtime\\Workflow\\": "src/"
2729
}
2830
},
2931
"autoload-dev": {
3032
"psr-4": {
31-
"functional\\Kiboko\\Component\\Runtime\\WorkflowConsoleRuntime\\": "tests/unit/"
33+
"functional\\Kiboko\\Component\\Runtime\\Workflow\\": "tests/unit/"
3234
}
3335
},
3436
"config": {

composer.lock

Lines changed: 106 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/WorkflowConsoleRuntime.php

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,9 @@
11
<?php declare(strict_types=1);
22

3-
namespace Kiboko\Component\Runtime\WorkflowConsoleRuntime;
3+
namespace Kiboko\Component\Runtime\Workflow;
44

5+
use Kiboko\Component\Runtime\Pipeline\PipelineConsoleRuntime;
6+
use Kiboko\Component\State;
57
use Kiboko\Component\Pipeline\Pipeline;
68
use Kiboko\Contract\Pipeline\PipelineRunnerInterface;
79
use Kiboko\Contract\Pipeline\RunnableInterface;
@@ -10,24 +12,24 @@
1012

1113
final class WorkflowConsoleRuntime implements WorkflowRuntimeInterface
1214
{
13-
private StateOutput\Workflow $state;
15+
private State\StateOutput\Workflow $state;
1416

1517
public function __construct(
1618
private ConsoleOutput $output,
1719
private SchedulingInterface $workflow,
1820
private PipelineRunnerInterface $pipelineRunner,
1921
) {
20-
$this->state = new StateOutput\Workflow($output);
22+
$this->state = new State\StateOutput\Workflow($output);
2123
}
2224

23-
public function loadPipeline(string $filename): Workflow\PipelineConsoleRuntime
25+
public function loadPipeline(string $filename): PipelineConsoleRuntime
2426
{
2527
$factory = require $filename;
2628

2729
$pipeline = new Pipeline($this->pipelineRunner);
2830
$this->workflow->job($pipeline);
2931

30-
return $factory(new Workflow\PipelineConsoleRuntime($this->output, $pipeline, $this->state->withPipeline(basename($filename))));
32+
return $factory(new PipelineConsoleRuntime($this->output, $pipeline, $this->state->withPipeline(basename($filename))));
3133
}
3234

3335
public function job(RunnableInterface $job): self

src/WorkflowRuntimeInterface.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
<?php declare(strict_types=1);
22

3-
namespace Kiboko\Component\Runtime\WorkflowConsoleRuntime;
3+
namespace Kiboko\Component\Runtime\Workflow;
44

55
use Kiboko\Contract\Pipeline\RunnableInterface;
66
use Kiboko\Contract\Pipeline\SchedulingInterface;

0 commit comments

Comments
 (0)