diff --git a/.claude/CLAUDE.md b/.claude/CLAUDE.md index 63531bc..7137569 100644 --- a/.claude/CLAUDE.md +++ b/.claude/CLAUDE.md @@ -52,7 +52,7 @@ Each config's `help:` line shows a concrete example. `-c key:"'value'"` injects - **Model / lifecycle** (`src/Model/`): a process is a graph of tasks; each task is a service implementing `TaskInterface::execute(ProcessState $state)`. `ProcessState` is the data bus passed task-to-task — `getInput()`/`setOutput()`/`setErrorOutput()`, `stop()`, plus `getContext()` and `getContextualizedOption()` (the `-c key:value` values). Optional lifecycle interfaces refine a task: `IterableTaskInterface` (emit many outputs from one input), `BlockingTaskInterface` (wait for all inputs before proceeding), `Initializable/Flushable/FinalizableTaskInterface`, and `AbstractConfigurableTask` (OptionsResolver-based options). - **Tasks** (`src/Task/`): the generic building blocks referenced in configs — `ConstantOutputTask`, `TransformerTask`, `File/Csv/*`, `File/JsonStream/*`, `File/Xml|Yaml/*`, `Serialization/*` (normalize/denormalize/(de)serialize), `Validation/ValidatorTask`, `Debug/*` (`DebugTask`, `DieTask`, `StopwatchTask`, `ErrorForwarderTask`), `Reporting/*` (`LoggerTask`, stat counters), aggregators/iterators, and `Process/*` (run sub-processes or shell commands). - **Transformers** (`src/Transformer/`): the value-mapping library used inside `TransformerTask` and `generic_transformers` — `MappingTransformer`, `CallbackTransformer`, `CastTransformer`, `RulesTransformer`, `Array/*`, `String/*` (implode, explode, slugify, sprintf, preg_match…), `Date/*`, `Object/*`, `Serialization/*`, `Xml/XpathEvaluatorTransformer`. -- **Registries** (`src/Registry/`): `ProcessConfigurationRegistry` and `TransformerRegistry` resolve the `@service` / transformer names used in YAML. +- **Registries** (`src/Registry/`): `ProcessConfigurationRegistry` and `TransformerRegistry` resolve the process configurations and the transformer codes used in YAML; `TaskRegistry` resolves the task codes (`task: `, declared by the `code` attribute of the `cleverage.task` tag or `#[AsTask]`). **Bridge bundles** each add a small set of tasks (`src/Task/`) plus a client/adapter concept wired in `config/services.yaml`: - `doctrine-process-bundle` — DB & entity tasks: `Database/DatabaseReaderTask`, `DatabaseUpdaterTask`, and `EntityManager/*` (`DoctrineReaderTask`, `DoctrineWriterTask`, `DoctrineBatchWriterTask`, cleaner/detacher/refresher/remover/clearer). @@ -89,7 +89,7 @@ clever_age_process: # entrypoint_type: file|text, default values, Symfony validation constraints) tasks: : - service: '@CleverAge\ProcessBundle\Task\...' # the task class, referenced as a service + task: # the task code (e.g. transformer, debug, rest_request) options: { ... } outputs: [ , ... ] # edges to downstream tasks (fan-out allowed) error_strategy: stop|skip|... diff --git a/config/packages/process/demo.archive.unzip.yaml b/config/packages/process/demo.archive.unzip.yaml index da50a7b..29784b9 100644 --- a/config/packages/process/demo.archive.unzip.yaml +++ b/config/packages/process/demo.archive.unzip.yaml @@ -11,17 +11,17 @@ clever_age_process: target: Foo tasks: constant: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: filename: '%kernel.project_dir%/var/data/archive.zip' destination: '%kernel.project_dir%/var/data/unzip_archive' outputs: entry entry: - service: '@CleverAge\ArchiveProcessBundle\Task\UnzipTask' + task: archive_unzip outputs: directory directory: - service: '@CleverAge\ProcessBundle\Task\File\InputFolderBrowserTask' + task: input_folder_browser outputs: debug debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.unzip_invalid_input.yaml b/config/packages/process/demo.archive.unzip_invalid_input.yaml index 243c52c..086b51e 100644 --- a/config/packages/process/demo.archive.unzip_invalid_input.yaml +++ b/config/packages/process/demo.archive.unzip_invalid_input.yaml @@ -12,16 +12,16 @@ clever_age_process: target: Foo tasks: filename: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: '%kernel.project_dir%/var/data/archive.zip' outputs: [unzip] unzip: - service: '@CleverAge\ArchiveProcessBundle\Task\UnzipTask' + task: archive_unzip options: destination: '%kernel.project_dir%/var/data/unzip_archive' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.unzip_not_a_zip.yaml b/config/packages/process/demo.archive.unzip_not_a_zip.yaml index 593daec..b6f9f0d 100644 --- a/config/packages/process/demo.archive.unzip_not_a_zip.yaml +++ b/config/packages/process/demo.archive.unzip_not_a_zip.yaml @@ -12,11 +12,11 @@ clever_age_process: target: Foo tasks: unzip: - service: '@CleverAge\ArchiveProcessBundle\Task\UnzipTask' + task: archive_unzip options: filename: '%kernel.project_dir%/var/data/sample.txt' destination: '%kernel.project_dir%/var/data/unzip_archive' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.unzip_write_failure.yaml b/config/packages/process/demo.archive.unzip_write_failure.yaml index ea8b9e4..b72ca4f 100644 --- a/config/packages/process/demo.archive.unzip_write_failure.yaml +++ b/config/packages/process/demo.archive.unzip_write_failure.yaml @@ -12,11 +12,11 @@ clever_age_process: target: Foo tasks: unzip: - service: '@CleverAge\ArchiveProcessBundle\Task\UnzipTask' + task: archive_unzip options: filename: '%kernel.project_dir%/var/data/archive.zip' destination: '%kernel.project_dir%/var/data/sample.txt' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.zip.yaml b/config/packages/process/demo.archive.zip.yaml index 0abdfc4..2dd18bd 100644 --- a/config/packages/process/demo.archive.zip.yaml +++ b/config/packages/process/demo.archive.zip.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ArchiveProcessBundle\Task\ZipTask' + task: archive_zip options: filename: '%kernel.project_dir%/var/data/zip_archive.zip' files: @@ -19,4 +19,4 @@ clever_age_process: files_base_path: '%kernel.project_dir%/var/data' outputs: debug debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.zip_files_base_path.yaml b/config/packages/process/demo.archive.zip_files_base_path.yaml index dafcdb6..2265800 100644 --- a/config/packages/process/demo.archive.zip_files_base_path.yaml +++ b/config/packages/process/demo.archive.zip_files_base_path.yaml @@ -13,7 +13,7 @@ clever_age_process: tasks: # Extracts archived_file.txt into /backup// unzip: - service: '@CleverAge\ArchiveProcessBundle\Task\UnzipTask' + task: archive_unzip options: filename: '%kernel.project_dir%/var/data/archive.zip' destination: 'var/data/demo_zip_files_base_path/backup/var/data' @@ -21,7 +21,7 @@ clever_age_process: # UnzipTask outputs the destination directory (a string): replace it with the ZipTask input zip_input: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: constant: @@ -31,11 +31,11 @@ clever_age_process: # Paths are relative to the project directory: expected entry "demo_zip_files_base_path/backup/var/data/archived_file.txt" zip: - service: '@CleverAge\ArchiveProcessBundle\Task\ZipTask' + task: archive_zip options: filename: '%kernel.project_dir%/var/data/demo_zip_files_base_path.zip' files_base_path: 'var/data' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.zip_multiple_inputs.yaml b/config/packages/process/demo.archive.zip_multiple_inputs.yaml index 94e8be4..dc74240 100644 --- a/config/packages/process/demo.archive.zip_multiple_inputs.yaml +++ b/config/packages/process/demo.archive.zip_multiple_inputs.yaml @@ -12,7 +12,7 @@ clever_age_process: target: Foo tasks: inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - filename: '%kernel.project_dir%/var/data/demo_zip_multiple_inputs_1.zip' @@ -22,10 +22,10 @@ clever_age_process: outputs: [zip] zip: - service: '@CleverAge\ArchiveProcessBundle\Task\ZipTask' + task: archive_zip options: files_base_path: '%kernel.project_dir%/var/data' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.zip_relative_path.yaml b/config/packages/process/demo.archive.zip_relative_path.yaml index a407942..f98c89a 100644 --- a/config/packages/process/demo.archive.zip_relative_path.yaml +++ b/config/packages/process/demo.archive.zip_relative_path.yaml @@ -12,11 +12,11 @@ clever_age_process: target: Foo tasks: zip: - service: '@CleverAge\ArchiveProcessBundle\Task\ZipTask' + task: archive_zip options: filename: '%kernel.project_dir%/var/data/demo_zip_relative_path.zip' files: 'var/data/sample.txt' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.archive.zip_write_failure.yaml b/config/packages/process/demo.archive.zip_write_failure.yaml index 993a94a..ed851ba 100644 --- a/config/packages/process/demo.archive.zip_write_failure.yaml +++ b/config/packages/process/demo.archive.zip_write_failure.yaml @@ -12,7 +12,7 @@ clever_age_process: target: Foo tasks: zip: - service: '@CleverAge\ArchiveProcessBundle\Task\ZipTask' + task: archive_zip options: filename: '%kernel.project_dir%/var/data/missing_directory/demo_zip_write_failure.zip' files: '%kernel.project_dir%/var/data/sample.txt' @@ -20,4 +20,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.blocking.no_direct_iterable_ancestor.yaml b/config/packages/process/demo.blocking.no_direct_iterable_ancestor.yaml index c9c735b..3966590 100644 --- a/config/packages/process/demo.blocking.no_direct_iterable_ancestor.yaml +++ b/config/packages/process/demo.blocking.no_direct_iterable_ancestor.yaml @@ -10,21 +10,21 @@ clever_age_process: Expected: two lines, "indirect: [\"item 1\",\"item 2\",\"item 3\"]" and "no iterable: [\"constant\"]" tasks: iterable: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [1, 2, 3] outputs: [format] format: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: sprintf: { format: 'item %s' } outputs: [indirect_aggregate] indirect_aggregate: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [indirect_dump] indirect_dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } @@ -32,15 +32,15 @@ clever_age_process: outputs: [debug] constant: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: constant outputs: [no_iterable_aggregate] no_iterable_aggregate: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [no_iterable_dump] no_iterable_dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } @@ -48,4 +48,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.blocking.two_blocking_children.yaml b/config/packages/process/demo.blocking.two_blocking_children.yaml index 7d252d4..edd920e 100644 --- a/config/packages/process/demo.blocking.two_blocking_children.yaml +++ b/config/packages/process/demo.blocking.two_blocking_children.yaml @@ -9,16 +9,16 @@ clever_age_process: Expected: two lines, "first: [1,2,3]" and "second: [1,2,3]" tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [1, 2, 3] outputs: [first_aggregate, second_aggregate] first_aggregate: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [first_dump] first_dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } @@ -26,10 +26,10 @@ clever_age_process: outputs: [debug] second_aggregate: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [second_dump] second_dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } @@ -37,4 +37,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.blocking.two_iterable_ancestors.yaml b/config/packages/process/demo.blocking.two_iterable_ancestors.yaml index 3412887..cf4d604 100644 --- a/config/packages/process/demo.blocking.two_iterable_ancestors.yaml +++ b/config/packages/process/demo.blocking.two_iterable_ancestors.yaml @@ -10,21 +10,21 @@ clever_age_process: Expected: a single line, "both: [1,2,3,4]" tasks: first_iterable: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [1, 2] outputs: [aggregate] second_iterable: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [3, 4] outputs: [aggregate] aggregate: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } @@ -32,4 +32,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.cache.get_invalid_input.yaml b/config/packages/process/demo.cache.get_invalid_input.yaml index 78a278d..62a948e 100644 --- a/config/packages/process/demo.cache.get_invalid_input.yaml +++ b/config/packages/process/demo.cache.get_invalid_input.yaml @@ -8,16 +8,16 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.cache.get_invalid_input tasks: sku: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'key1' outputs: [ get ] get: - service: '@CleverAge\CacheProcessBundle\Task\GetTask' + task: cache_get options: adapter: 'memory' # key is given by the input outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.cache.get_on_miss.yaml b/config/packages/process/demo.cache.get_on_miss.yaml index c2bb8c5..b2873e3 100644 --- a/config/packages/process/demo.cache.get_on_miss.yaml +++ b/config/packages/process/demo.cache.get_on_miss.yaml @@ -9,7 +9,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.cache.get_on_miss tasks: keys: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - key: 'key1' @@ -18,7 +18,7 @@ clever_age_process: outputs: [ get ] get: - service: '@CleverAge\CacheProcessBundle\Task\GetTask' + task: cache_get options: adapter: 'memory' # key is given by the input on_miss: skip @@ -26,10 +26,10 @@ clever_age_process: error_outputs: [ compute ] found: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug compute: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: mapping: @@ -44,9 +44,9 @@ clever_age_process: outputs: [ set, computed ] set: - service: '@CleverAge\CacheProcessBundle\Task\SetTask' + task: cache_set options: adapter: 'memory' # key and value are given by the input computed: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.cache.set_expires_after.yaml b/config/packages/process/demo.cache.set_expires_after.yaml index 9a30dc0..23ece21 100644 --- a/config/packages/process/demo.cache.set_expires_after.yaml +++ b/config/packages/process/demo.cache.set_expires_after.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.cache.set_expires_after tasks: set: - service: '@CleverAge\CacheProcessBundle\Task\SetTask' + task: cache_set options: adapter: 'memory' key: 'short_lived' @@ -17,7 +17,7 @@ clever_age_process: outputs: [ get_before, wait ] get_before: - service: '@CleverAge\CacheProcessBundle\Task\GetTask' + task: cache_get options: adapter: 'memory' key: 'short_lived' @@ -25,7 +25,7 @@ clever_age_process: outputs: [ debug ] wait: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: constant: @@ -34,11 +34,11 @@ clever_age_process: outputs: [ get_after ] get_after: - service: '@CleverAge\CacheProcessBundle\Task\GetTask' + task: cache_get options: adapter: 'memory' key: 'short_lived' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.cache.set_get.yaml b/config/packages/process/demo.cache.set_get.yaml index 58aa0e5..f260dc6 100644 --- a/config/packages/process/demo.cache.set_get.yaml +++ b/config/packages/process/demo.cache.set_get.yaml @@ -11,11 +11,11 @@ clever_age_process: target: Foo tasks: start: - service: '@CleverAge\ProcessBundle\Task\DummyTask' + task: dummy outputs: [ data, get, get_missing ] data: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output outputs: [ format ] options: output: @@ -32,7 +32,7 @@ clever_age_process: column2: null column3: value3-3 format: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: mapping: @@ -44,23 +44,23 @@ clever_age_process: outputs: [ set ] set: - service: '@CleverAge\CacheProcessBundle\Task\SetTask' + task: cache_set options: adapter: 'memory' # key and value are given by the input get: - service: '@CleverAge\CacheProcessBundle\Task\GetTask' + task: cache_get options: adapter: 'memory' key: 'key2' outputs: [ debug ] get_missing: - service: '@CleverAge\CacheProcessBundle\Task\GetTask' + task: cache_get options: adapter: 'memory' key: 'missing' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.cache.set_invalid_input_option.yaml b/config/packages/process/demo.cache.set_invalid_input_option.yaml index 6cb85c4..a294488 100644 --- a/config/packages/process/demo.cache.set_invalid_input_option.yaml +++ b/config/packages/process/demo.cache.set_invalid_input_option.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.cache.set_invalid_input_option tasks: item: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: adapter: 1 @@ -17,6 +17,6 @@ clever_age_process: outputs: [ set ] set: - service: '@CleverAge\CacheProcessBundle\Task\SetTask' + task: cache_set options: adapter: 'memory' # key and value are given by the input diff --git a/config/packages/process/demo.cache.set_invalid_key.yaml b/config/packages/process/demo.cache.set_invalid_key.yaml index fe978a9..41af68d 100644 --- a/config/packages/process/demo.cache.set_invalid_key.yaml +++ b/config/packages/process/demo.cache.set_invalid_key.yaml @@ -9,7 +9,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.cache.set_invalid_key tasks: item: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: key: 'ABC/001' @@ -17,6 +17,6 @@ clever_age_process: outputs: [ set ] set: - service: '@CleverAge\CacheProcessBundle\Task\SetTask' + task: cache_set options: adapter: 'memory' # key and value are given by the input diff --git a/config/packages/process/demo.constant_iterable_output.yaml b/config/packages/process/demo.constant_iterable_output.yaml index 66f1b6c..b39a0a7 100644 --- a/config/packages/process/demo.constant_iterable_output.yaml +++ b/config/packages/process/demo.constant_iterable_output.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: id: 123 @@ -19,4 +19,4 @@ clever_age_process: lastname: Test2 outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.constant_output.yaml b/config/packages/process/demo.constant_output.yaml index ede058e..02a3a5e 100644 --- a/config/packages/process/demo.constant_output.yaml +++ b/config/packages/process/demo.constant_output.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 123 @@ -19,4 +19,4 @@ clever_age_process: lastname: Test2 outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.counter.yaml b/config/packages/process/demo.counter.yaml index d5d142c..f036f67 100644 --- a/config/packages/process/demo.counter.yaml +++ b/config/packages/process/demo.counter.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: test1: test1 @@ -25,9 +25,9 @@ clever_age_process: test9: test9 outputs: [ counter ] counter: - service: '@CleverAge\ProcessBundle\Task\CounterTask' + task: counter options: flush_every: 3 outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.date.date_parser.yaml b/config/packages/process/demo.date.date_parser.yaml index dd62d03..514c681 100644 --- a/config/packages/process/demo.date.date_parser.yaml +++ b/config/packages/process/demo.date.date_parser.yaml @@ -12,13 +12,13 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ parse_string, parse_immutable ] options: output: '2026-09-28 12:34:56' parse_string: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -26,7 +26,7 @@ clever_age_process: format: 'Y-m-d H:i:s' parse_immutable: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -36,4 +36,4 @@ clever_age_process: format: 'Y-m-d H:i:s' debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.debug.yaml b/config/packages/process/demo.debug.yaml index 13cf8e0..9f85000 100644 --- a/config/packages/process/demo.debug.yaml +++ b/config/packages/process/demo.debug.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 123 @@ -20,4 +20,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.die.yaml b/config/packages/process/demo.die.yaml index 29fc198..5e9df82 100644 --- a/config/packages/process/demo.die.yaml +++ b/config/packages/process/demo.die.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 123 @@ -20,4 +20,4 @@ clever_age_process: outputs: [die] die: - service: '@CleverAge\ProcessBundle\Task\Debug\DieTask' + task: die diff --git a/config/packages/process/demo.doctrine.database.read.yaml b/config/packages/process/demo.doctrine.database.read.yaml index 40085c7..33c8853 100644 --- a/config/packages/process/demo.doctrine.database.read.yaml +++ b/config/packages/process/demo.doctrine.database.read.yaml @@ -11,10 +11,10 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\Database\DatabaseReaderTask' + task: doctrine_database_reader options: table: 'book' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' \ No newline at end of file + task: debug \ No newline at end of file diff --git a/config/packages/process/demo.doctrine.database.read_array_parameter.yaml b/config/packages/process/demo.doctrine.database.read_array_parameter.yaml index a134992..fb62676 100644 --- a/config/packages/process/demo.doctrine.database.read_array_parameter.yaml +++ b/config/packages/process/demo.doctrine.database.read_array_parameter.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.database.read_array_parameter tasks: read: - service: '@CleverAge\DoctrineProcessBundle\Task\Database\DatabaseReaderTask' + task: doctrine_database_reader options: sql: 'SELECT id, title FROM book WHERE title IN (:titles) ORDER BY id' table: 'book' @@ -19,4 +19,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.database.read_multiple_inputs.yaml b/config/packages/process/demo.doctrine.database.read_multiple_inputs.yaml index b961b79..6b30b10 100644 --- a/config/packages/process/demo.doctrine.database.read_multiple_inputs.yaml +++ b/config/packages/process/demo.doctrine.database.read_multiple_inputs.yaml @@ -8,20 +8,20 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.database.read_multiple_inputs tasks: inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ 'first', 'second', 'third' ] outputs: [ read ] read: - service: '@CleverAge\DoctrineProcessBundle\Task\Database\DatabaseReaderTask' + task: doctrine_database_reader options: sql: 'SELECT title FROM book ORDER BY id' table: 'book' outputs: [ title ] title: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: property_accessor: @@ -29,4 +29,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.database.read_paginate.yaml b/config/packages/process/demo.doctrine.database.read_paginate.yaml index 0155956..198203f 100644 --- a/config/packages/process/demo.doctrine.database.read_paginate.yaml +++ b/config/packages/process/demo.doctrine.database.read_paginate.yaml @@ -12,7 +12,7 @@ clever_age_process: target: Foo tasks: read: - service: '@CleverAge\DoctrineProcessBundle\Task\Database\DatabaseReaderTask' + task: doctrine_database_reader options: table: 'book' sql: 'SELECT id FROM book ORDER BY id' @@ -20,7 +20,7 @@ clever_age_process: outputs: [ids] ids: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: array_map: @@ -32,4 +32,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.database.read_sql_without_table.yaml b/config/packages/process/demo.doctrine.database.read_sql_without_table.yaml index c44ea99..9503c4f 100644 --- a/config/packages/process/demo.doctrine.database.read_sql_without_table.yaml +++ b/config/packages/process/demo.doctrine.database.read_sql_without_table.yaml @@ -8,10 +8,10 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.database.read_sql_without_table tasks: read: - service: '@CleverAge\DoctrineProcessBundle\Task\Database\DatabaseReaderTask' + task: doctrine_database_reader options: sql: 'SELECT id, title FROM book ORDER BY id' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.database.update.yaml b/config/packages/process/demo.doctrine.database.update.yaml index 20a3749..02785a8 100644 --- a/config/packages/process/demo.doctrine.database.update.yaml +++ b/config/packages/process/demo.doctrine.database.update.yaml @@ -19,7 +19,7 @@ clever_age_process: value: King tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\Database\DatabaseUpdaterTask' + task: doctrine_database_updater options: sql: 'update author set firstname = :firstname, lastname = :lastname' input_as_params: false @@ -29,4 +29,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.entitymanager.batch_writer.yaml b/config/packages/process/demo.doctrine.entitymanager.batch_writer.yaml index 2855ca8..e3d3567 100644 --- a/config/packages/process/demo.doctrine.entitymanager.batch_writer.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.batch_writer.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - author1: @@ -25,30 +25,30 @@ clever_age_process: lastname: Lastname outputs: [iterate] iterate: - service: '@CleverAge\ProcessBundle\Task\InputIteratorTask' + task: input_iterator outputs: [denormalizer] denormalizer: - service: '@CleverAge\ProcessBundle\Task\Serialization\DenormalizerTask' + task: denormalizer options: class: App\Entity\Author outputs: [batch_write] batch_write: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineBatchWriterTask' + task: doctrine_batch_writer outputs: [aggregate_write] options: batch_count: 2 aggregate_write: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [fetch] fetch: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Author' criteria: lastname: 'Lastname' outputs: [agregate_fetch] agregate_fetch: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' \ No newline at end of file + task: debug \ No newline at end of file diff --git a/config/packages/process/demo.doctrine.entitymanager.detacher_null_input.yaml b/config/packages/process/demo.doctrine.entitymanager.detacher_null_input.yaml index 723794a..0fbc764 100644 --- a/config/packages/process/demo.doctrine.entitymanager.detacher_null_input.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.detacher_null_input.yaml @@ -8,4 +8,4 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.entitymanager.detacher_null_input tasks: detach: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineDetacherTask' + task: doctrine_detacher diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_cleaner.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_cleaner.yaml index fe135bd..a050942 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_cleaner.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_cleaner.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Author' criteria: @@ -21,8 +21,8 @@ clever_age_process: outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug outputs: [clean] clean: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineCleanerTask' + task: doctrine_cleaner diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_clearer.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_clearer.yaml index 1d4e4df..f1ccc7b 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_clearer.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_clearer.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Author' criteria: @@ -21,8 +21,8 @@ clever_age_process: outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug outputs: [clear] clear: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\ClearEntityManagerTask' + task: doctrine_clear_entity_manager diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_detacher.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_detacher.yaml index b82ea12..f2c6f66 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_detacher.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_detacher.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Author' criteria: @@ -21,8 +21,8 @@ clever_age_process: outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug outputs: [detach] detach: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineDetacherTask' + task: doctrine_detacher diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_entity_manager.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_entity_manager.yaml index 823d897..8c26e57 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_entity_manager.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_entity_manager.yaml @@ -8,11 +8,11 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.entitymanager.reader_entity_manager tasks: read: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Book' entity_manager: 'unknown' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_multiple_inputs.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_multiple_inputs.yaml index af0c8c4..8cb4e40 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_multiple_inputs.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_multiple_inputs.yaml @@ -8,19 +8,19 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.entitymanager.reader_multiple_inputs tasks: inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ 'first', 'second', 'third' ] outputs: [ read ] read: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Book' outputs: [ title ] title: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: property_accessor: @@ -28,4 +28,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_refresher.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_refresher.yaml index 59f2f29..40f2bcb 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_refresher.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_refresher.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Author' criteria: @@ -21,23 +21,23 @@ clever_age_process: outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug outputs: [modify] modify: - service: '@CleverAge\ProcessBundle\Task\PropertySetterTask' + task: property_setter options: values: firstname: Gérard outputs: [dump_modified] dump_modified: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug outputs: [refresh] refresh: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineRefresherTask' + task: doctrine_refresher outputs: [dump_refreshed] dump_refreshed: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.entitymanager.reader_remover.yaml b/config/packages/process/demo.doctrine.entitymanager.reader_remover.yaml index f8d1205..9586cf0 100644 --- a/config/packages/process/demo.doctrine.entitymanager.reader_remover.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.reader_remover.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Book' criteria: @@ -19,15 +19,15 @@ clever_age_process: outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug outputs: [remover] remover: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineRemoverTask' + task: doctrine_remover outputs: [refetch] refetch: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Book' criteria: @@ -35,4 +35,4 @@ clever_age_process: outputs: [dumpnullid] dumpnullid: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.doctrine.entitymanager.remover_null_input.yaml b/config/packages/process/demo.doctrine.entitymanager.remover_null_input.yaml index 04620bf..c12bec0 100644 --- a/config/packages/process/demo.doctrine.entitymanager.remover_null_input.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.remover_null_input.yaml @@ -8,4 +8,4 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.doctrine.entitymanager.remover_null_input tasks: remove: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineRemoverTask' + task: doctrine_remover diff --git a/config/packages/process/demo.doctrine.entitymanager.writer.yaml b/config/packages/process/demo.doctrine.entitymanager.writer.yaml index ab9b121..47c6e08 100644 --- a/config/packages/process/demo.doctrine.entitymanager.writer.yaml +++ b/config/packages/process/demo.doctrine.entitymanager.writer.yaml @@ -11,26 +11,26 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: firstname: Isaac lastname: Asimov outputs: [denormalize] denormalize: - service: '@CleverAge\ProcessBundle\Task\Serialization\DenormalizerTask' + task: denormalizer options: class: App\Entity\Author outputs: [save] save: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineWriterTask' + task: doctrine_writer outputs: [fetch] fetch: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineReaderTask' + task: doctrine_reader options: class_name: 'App\Entity\Author' criteria: lastname: 'Asimov' outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' \ No newline at end of file + task: debug \ No newline at end of file diff --git a/config/packages/process/demo.dummy.yaml b/config/packages/process/demo.dummy.yaml index eb97bae..e14358d 100644 --- a/config/packages/process/demo.dummy.yaml +++ b/config/packages/process/demo.dummy.yaml @@ -11,10 +11,10 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\DummyTask' + task: dummy outputs: [ output1, output2 ] output1: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 123 @@ -22,7 +22,7 @@ clever_age_process: lastname: Test2 outputs: [ debug ] output2: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 456 @@ -30,4 +30,4 @@ clever_age_process: lastname: Test4 outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.error_context.yaml b/config/packages/process/demo.error_context.yaml index 8cab9aa..f93eef2 100644 --- a/config/packages/process/demo.error_context.yaml +++ b/config/packages/process/demo.error_context.yaml @@ -7,12 +7,12 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.error_context.empty_iterable -vv tasks: iterate: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [] outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug demo.error_context.property_setter: description: > @@ -21,16 +21,16 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.error_context.property_setter -vv tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: name: Foo outputs: [set] set: - service: '@CleverAge\ProcessBundle\Task\PropertySetterTask' + task: property_setter options: values: enabled: true # property path on an array: cannot be written outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.error_forwarder.yaml b/config/packages/process/demo.error_forwarder.yaml index 1b041ee..6f4ae44 100644 --- a/config/packages/process/demo.error_forwarder.yaml +++ b/config/packages/process/demo.error_forwarder.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: error1: Error 1 @@ -19,4 +19,4 @@ clever_age_process: error3: Error 3 outputs: [ error_forwarder ] error_forwarder: - service: '@CleverAge\ProcessBundle\Task\Debug\ErrorForwarderTask' + task: error_forwarder diff --git a/config/packages/process/demo.event_dispatcher.yaml b/config/packages/process/demo.event_dispatcher.yaml index f7f843a..b706f02 100644 --- a/config/packages/process/demo.event_dispatcher.yaml +++ b/config/packages/process/demo.event_dispatcher.yaml @@ -11,9 +11,9 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\Event\EventDispatcherTask' + task: event_dispatcher options: event_name: 'myapp.myevent' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.failed.yaml b/config/packages/process/demo.failed.yaml index c7e55bb..58082a7 100644 --- a/config/packages/process/demo.failed.yaml +++ b/config/packages/process/demo.failed.yaml @@ -11,4 +11,4 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output diff --git a/config/packages/process/demo.file.csv_reader.yaml b/config/packages/process/demo.file.csv_reader.yaml index 5d15e75..7e11e4e 100644 --- a/config/packages/process/demo.file.csv_reader.yaml +++ b/config/packages/process/demo.file.csv_reader.yaml @@ -11,14 +11,14 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\File\Csv\CsvReaderTask' + task: csv_reader outputs: [ log_line, dump ] options: file_path: '%kernel.project_dir%/var/data/sample.csv' log_line: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Read line level: info dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.csv_writer.yaml b/config/packages/process/demo.file.csv_writer.yaml index ba98850..d179df8 100644 --- a/config/packages/process/demo.file.csv_writer.yaml +++ b/config/packages/process/demo.file.csv_writer.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output outputs: [ write ] options: output: @@ -25,6 +25,6 @@ clever_age_process: column2: null column3: value3-3 write: - service: '@CleverAge\ProcessBundle\Task\File\Csv\CsvWriterTask' + task: csv_writer options: file_path: '%kernel.project_dir%/var/data/csv_writer_{date_time}.csv' diff --git a/config/packages/process/demo.file.file_reader.yaml b/config/packages/process/demo.file.file_reader.yaml index ef5281b..55c0b96 100644 --- a/config/packages/process/demo.file.file_reader.yaml +++ b/config/packages/process/demo.file.file_reader.yaml @@ -11,9 +11,9 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\File\FileReaderTask' + task: file_reader options: filename: '%kernel.project_dir%/var/data/sample.txt' outputs: debug debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.file_splitter.yaml b/config/packages/process/demo.file.file_splitter.yaml index 604d432..7abe384 100644 --- a/config/packages/process/demo.file.file_splitter.yaml +++ b/config/packages/process/demo.file.file_splitter.yaml @@ -11,10 +11,10 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\File\FileSplitterTask' + task: file_splitter outputs: [ dump ] options: file_path: '%kernel.project_dir%/var/data/json_stream_reader.json' max_lines: 1 dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.input_csv_reader.yaml b/config/packages/process/demo.file.input_csv_reader.yaml index d05d97a..cf31742 100644 --- a/config/packages/process/demo.file.input_csv_reader.yaml +++ b/config/packages/process/demo.file.input_csv_reader.yaml @@ -11,18 +11,18 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\File\FolderBrowserTask' + task: folder_browser options: folder_path: '%kernel.project_dir%/var/data' name_pattern: '*.csv' outputs: read read: - service: '@CleverAge\ProcessBundle\Task\File\Csv\InputCsvReaderTask' + task: input_csv_reader outputs: [ log_line, dump ] log_line: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Read line level: info dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.input_file_reader.yaml b/config/packages/process/demo.file.input_file_reader.yaml index 99bbe10..ac4add2 100644 --- a/config/packages/process/demo.file.input_file_reader.yaml +++ b/config/packages/process/demo.file.input_file_reader.yaml @@ -11,17 +11,17 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: '/var/data' outputs: directory directory: - service: '@CleverAge\ProcessBundle\Task\File\InputFolderBrowserTask' + task: input_folder_browser options: base_folder_path: '%kernel.project_dir%' outputs: read read: - service: '@CleverAge\ProcessBundle\Task\File\InputFileReaderTask' + task: input_file_reader outputs: debug debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.input_line_reader.yaml b/config/packages/process/demo.file.input_line_reader.yaml index 2ca8b8a..d3a7bce 100644 --- a/config/packages/process/demo.file.input_line_reader.yaml +++ b/config/packages/process/demo.file.input_line_reader.yaml @@ -11,17 +11,17 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\File\FolderBrowserTask' + task: folder_browser options: folder_path: '%kernel.project_dir%/var/data' outputs: read read: - service: '@CleverAge\ProcessBundle\Task\File\InputLineReaderTask' + task: input_line_reader outputs: [ log_line, dump ] log_line: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Read line level: info dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.json_stream_reader.yaml b/config/packages/process/demo.file.json_stream_reader.yaml index 3fc9d0b..f61dcbf 100644 --- a/config/packages/process/demo.file.json_stream_reader.yaml +++ b/config/packages/process/demo.file.json_stream_reader.yaml @@ -12,16 +12,16 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output outputs: read options: output: file_path: '%kernel.project_dir%/var/data/json_stream_reader.json' read: - service: '@CleverAge\ProcessBundle\Task\File\JsonStream\JsonStreamReaderTask' + task: json_stream_reader outputs: dump options: spl_file_object_flags: [] json_flags: [] # no JSON_THROW_ON_ERROR: invalid lines are skipped dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.json_stream_reader_scalar_line.yaml b/config/packages/process/demo.file.json_stream_reader_scalar_line.yaml index c5613e0..4472d71 100644 --- a/config/packages/process/demo.file.json_stream_reader_scalar_line.yaml +++ b/config/packages/process/demo.file.json_stream_reader_scalar_line.yaml @@ -7,17 +7,17 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.file.json_stream_reader_scalar_line -vv tasks: content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ write ] options: output: "{\"a\":1}\n42\n" write: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer outputs: [ read ] options: filename: '%kernel.project_dir%/var/data/json_stream_scalar_line.jsonl' read: - service: '@CleverAge\ProcessBundle\Task\File\JsonStream\JsonStreamReaderTask' + task: json_stream_reader outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.json_stream_writer.yaml b/config/packages/process/demo.file.json_stream_writer.yaml index c54283d..d7c1ff2 100644 --- a/config/packages/process/demo.file.json_stream_writer.yaml +++ b/config/packages/process/demo.file.json_stream_writer.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output outputs: [ write ] options: output: @@ -25,7 +25,7 @@ clever_age_process: column2: null column3: value3/3 write: - service: '@CleverAge\ProcessBundle\Task\File\JsonStream\JsonStreamWriterTask' + task: json_stream_writer options: file_path: '%kernel.project_dir%/var/data/json_stream_writer_{date_time}.json' spl_file_object_flags: [] diff --git a/config/packages/process/demo.file.json_stream_writer_append.yaml b/config/packages/process/demo.file.json_stream_writer_append.yaml index 20908da..275b2bd 100644 --- a/config/packages/process/demo.file.json_stream_writer_append.yaml +++ b/config/packages/process/demo.file.json_stream_writer_append.yaml @@ -9,20 +9,20 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.file.json_stream_writer_append -vv tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - { event: start } - { event: end } outputs: [ write ] write: - service: '@CleverAge\ProcessBundle\Task\File\JsonStream\JsonStreamWriterTask' + task: json_stream_writer options: file_path: '%kernel.project_dir%/var/data/json_stream_writer_append.jsonl' mode: ab outputs: [ read ] read: - service: '@CleverAge\ProcessBundle\Task\File\JsonStream\JsonStreamReaderTask' + task: json_stream_reader outputs: [ dump ] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.json_stream_writer_missing_dir.yaml b/config/packages/process/demo.file.json_stream_writer_missing_dir.yaml index e76a6da..ba90004 100644 --- a/config/packages/process/demo.file.json_stream_writer_missing_dir.yaml +++ b/config/packages/process/demo.file.json_stream_writer_missing_dir.yaml @@ -7,16 +7,16 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.file.json_stream_writer_missing_dir -vv tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output outputs: [ write ] options: output: - column1: value1-1 - column1: value1-2 write: - service: '@CleverAge\ProcessBundle\Task\File\JsonStream\JsonStreamWriterTask' + task: json_stream_writer outputs: [ debug ] options: file_path: '%kernel.project_dir%/var/data/json_stream_missing_dir/sub/out.jsonl' debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.line_reader.yaml b/config/packages/process/demo.file.line_reader.yaml index c832506..8aba21d 100644 --- a/config/packages/process/demo.file.line_reader.yaml +++ b/config/packages/process/demo.file.line_reader.yaml @@ -11,17 +11,17 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\File\LineReaderTask' + task: line_reader options: filename: '%kernel.project_dir%/var/data/sample.txt' outputs: array array: - service: '@CleverAge\ProcessBundle\Task\InputAggregatorTask' + task: input_aggregator options: input_codes: { entry: entry } outputs: transform transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: mapping: @@ -49,4 +49,4 @@ clever_age_process: trim: ~ outputs: debug debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.file.xml_stream_reader.yaml b/config/packages/process/demo.file.xml_stream_reader.yaml index 350dac5..bd9f290 100644 --- a/config/packages/process/demo.file.xml_stream_reader.yaml +++ b/config/packages/process/demo.file.xml_stream_reader.yaml @@ -9,13 +9,13 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.file.xml_stream_reader -vv tasks: read: - service: '@CleverAge\ProcessBundle\Task\File\Xml\XmlStreamReaderTask' + task: xml_stream_reader options: file_path: '%kernel.project_dir%/var/data/xml_stream_reader.xml' node_name: product outputs: [ transform ] transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: xpath_evaluator: @@ -25,4 +25,4 @@ clever_age_process: price: 'g:price/text()' outputs: [ dump ] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.flysystem.fetch_missing_input.yaml b/config/packages/process/demo.flysystem.fetch_missing_input.yaml index bbd2d3d..c621ff3 100644 --- a/config/packages/process/demo.flysystem.fetch_missing_input.yaml +++ b/config/packages/process/demo.flysystem.fetch_missing_input.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.flysystem.fetch_missing_input && ls var/storage/fetch_source var/storage/fetch_destination tasks: clean: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: Empty both storages options: output: @@ -17,33 +17,33 @@ clever_age_process: outputs: [ remove_storages ] remove_storages: - service: '@CleverAge\ProcessBundle\Task\File\FileRemoverTask' + task: file_remover outputs: [ content ] content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Some data' outputs: [ write_0 ] write_0: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/a.txt' outputs: [ inputs ] inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ 'missing.txt', 'a.txt' ] outputs: [ task ] task: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch options: source_filesystem: 'local.storage.fetch_source' destination_filesystem: 'local.storage.fetch_destination' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.flysystem.fetch_multiple_inputs.yaml b/config/packages/process/demo.flysystem.fetch_multiple_inputs.yaml index 0293fbd..1ac9de5 100644 --- a/config/packages/process/demo.flysystem.fetch_multiple_inputs.yaml +++ b/config/packages/process/demo.flysystem.fetch_multiple_inputs.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.flysystem.fetch_multiple_inputs && ls var/storage/fetch_source var/storage/fetch_destination tasks: clean: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: Empty both storages options: output: @@ -17,45 +17,45 @@ clever_age_process: outputs: [ remove_storages ] remove_storages: - service: '@CleverAge\ProcessBundle\Task\File\FileRemoverTask' + task: file_remover outputs: [ content ] content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Some data' outputs: [ write_0 ] write_0: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/a.txt' outputs: [ write_1 ] write_1: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/b.txt' outputs: [ write_2 ] write_2: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/0' outputs: [ inputs ] inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ 'a.txt', 'b.txt', 'a.txt', '0' ] outputs: [ task ] task: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch options: source_filesystem: 'local.storage.fetch_source' destination_filesystem: 'local.storage.fetch_destination' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.flysystem.fetch_pattern_multiple_inputs.yaml b/config/packages/process/demo.flysystem.fetch_pattern_multiple_inputs.yaml index 80adec6..e44c545 100644 --- a/config/packages/process/demo.flysystem.fetch_pattern_multiple_inputs.yaml +++ b/config/packages/process/demo.flysystem.fetch_pattern_multiple_inputs.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.flysystem.fetch_pattern_multiple_inputs && ls var/storage/fetch_source var/storage/fetch_destination tasks: clean: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: Empty both storages options: output: @@ -17,35 +17,35 @@ clever_age_process: outputs: [ remove_storages ] remove_storages: - service: '@CleverAge\ProcessBundle\Task\File\FileRemoverTask' + task: file_remover outputs: [ content ] content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Some data' outputs: [ write_0 ] write_0: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/a.txt' outputs: [ write_1 ] write_1: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/b.txt' outputs: [ inputs ] inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ 'first', 'second' ] outputs: [ task ] task: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch options: source_filesystem: 'local.storage.fetch_source' destination_filesystem: 'local.storage.fetch_destination' @@ -53,4 +53,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.flysystem.fetch_write_failure.yaml b/config/packages/process/demo.flysystem.fetch_write_failure.yaml index 5345769..b9fff19 100644 --- a/config/packages/process/demo.flysystem.fetch_write_failure.yaml +++ b/config/packages/process/demo.flysystem.fetch_write_failure.yaml @@ -12,33 +12,33 @@ clever_age_process: target: Foo tasks: content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Some important data' outputs: [write_source] write_source: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer description: The file to copy, in local.storage options: filename: '%local.storage.dir%/demo_fetch_write_failure.txt' outputs: [block_destination] block_destination: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer description: Creates a directory named like the file in local.storage.fetch_failure, so writing the file fails options: filename: '%kernel.project_dir%/var/storage/fetch_failure/demo_fetch_write_failure.txt/blocker' outputs: [filename] filename: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'demo_fetch_write_failure.txt' outputs: [fetch] fetch: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch options: source_filesystem: 'local.storage' destination_filesystem: 'local.storage.fetch_failure' @@ -46,4 +46,4 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.flysystem.remove_files_input.yaml b/config/packages/process/demo.flysystem.remove_files_input.yaml index 73e8e76..5291973 100644 --- a/config/packages/process/demo.flysystem.remove_files_input.yaml +++ b/config/packages/process/demo.flysystem.remove_files_input.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.flysystem.remove_files_input && ls var/storage/fetch_source var/storage/fetch_destination tasks: clean: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: Empty both storages options: output: @@ -17,38 +17,38 @@ clever_age_process: outputs: [ remove_storages ] remove_storages: - service: '@CleverAge\ProcessBundle\Task\File\FileRemoverTask' + task: file_remover outputs: [ content ] content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Some data' outputs: [ write_0 ] write_0: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/a.txt' outputs: [ write_1 ] write_1: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/b.txt' outputs: [ inputs ] inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ [ 'a.txt', 'b.txt' ] ] outputs: [ task ] task: - service: '@CleverAge\FlysystemProcessBundle\Task\RemoveFileTask' + task: flysystem_remove_file options: filesystem: 'local.storage.fetch_source' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.flysystem.remove_missing_file.yaml b/config/packages/process/demo.flysystem.remove_missing_file.yaml index 6b8d8a9..5d49764 100644 --- a/config/packages/process/demo.flysystem.remove_missing_file.yaml +++ b/config/packages/process/demo.flysystem.remove_missing_file.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.flysystem.remove_missing_file && ls var/storage/fetch_source var/storage/fetch_destination tasks: clean: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: Empty both storages options: output: @@ -17,38 +17,38 @@ clever_age_process: outputs: [ remove_storages ] remove_storages: - service: '@CleverAge\ProcessBundle\Task\File\FileRemoverTask' + task: file_remover outputs: [ content ] content: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Some data' outputs: [ write_0 ] write_0: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/a.txt' outputs: [ write_1 ] write_1: - service: '@CleverAge\ProcessBundle\Task\File\FileWriterTask' + task: file_writer options: filename: '%kernel.project_dir%/var/storage/fetch_source/dir/b.txt' outputs: [ inputs ] inputs: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [ 'a.txt', 'missing.txt', 'dir' ] outputs: [ task ] task: - service: '@CleverAge\FlysystemProcessBundle\Task\RemoveFileTask' + task: flysystem_remove_file options: filesystem: 'local.storage.fetch_source' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.generic_transformer.yaml b/config/packages/process/demo.generic_transformer.yaml index 7b1c010..1167dc8 100644 --- a/config/packages/process/demo.generic_transformer.yaml +++ b/config/packages/process/demo.generic_transformer.yaml @@ -24,13 +24,13 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ with_suffix, without_suffix ] options: output: 'value' with_suffix: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -39,7 +39,7 @@ clever_age_process: suffix: ']' without_suffix: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -47,4 +47,4 @@ clever_age_process: prefix: '[' debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.input_aggregator.iterable.yaml b/config/packages/process/demo.input_aggregator.iterable.yaml index 14665b7..0e9fb9f 100644 --- a/config/packages/process/demo.input_aggregator.iterable.yaml +++ b/config/packages/process/demo.input_aggregator.iterable.yaml @@ -9,37 +9,37 @@ clever_age_process: Expected: three lines, {"a":"a1","b":"b1"}, {"a":"a2","b":"b2"} and {"a":"a3","b":"b3"} tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [1, 2, 3] outputs: [branch_a, branch_b] branch_a: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: sprintf: { format: 'a%s' } outputs: [aggregate] branch_b: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: sprintf: { format: 'b%s' } outputs: [aggregate] aggregate: - service: '@CleverAge\ProcessBundle\Task\InputAggregatorTask' + task: input_aggregator options: input_codes: branch_a: a branch_b: b outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.input_aggregator.skipped_branch.yaml b/config/packages/process/demo.input_aggregator.skipped_branch.yaml index 5790d0c..3053256 100644 --- a/config/packages/process/demo.input_aggregator.skipped_branch.yaml +++ b/config/packages/process/demo.input_aggregator.skipped_branch.yaml @@ -9,48 +9,48 @@ clever_age_process: Expected: three lines, {"a":"a1","b":"b1"}, {"a":"a3","b":"b3"} and {"a":"a5","b":"b5"} tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [1, 2, 3, 4, 5] outputs: [branch_a, branch_b] branch_a: - service: '@CleverAge\ProcessBundle\Task\FilterTask' + task: filter options: not_match: { '': 2 } outputs: [format_a] format_a: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: sprintf: { format: 'a%s' } outputs: [aggregate] branch_b: - service: '@CleverAge\ProcessBundle\Task\FilterTask' + task: filter options: not_match: { '': 4 } outputs: [format_b] format_b: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: sprintf: { format: 'b%s' } outputs: [aggregate] aggregate: - service: '@CleverAge\ProcessBundle\Task\InputAggregatorTask' + task: input_aggregator options: input_codes: format_a: a format_b: b outputs: [dump] dump: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: { callback: json_encode } outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.logger.yaml b/config/packages/process/demo.logger.yaml index c32bef3..c0a2c87 100644 --- a/config/packages/process/demo.logger.yaml +++ b/config/packages/process/demo.logger.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: level: warning message: DEMO LOGGER diff --git a/config/packages/process/demo.logs.retention.yaml b/config/packages/process/demo.logs.retention.yaml index dd0bcf2..37f5a7e 100644 --- a/config/packages/process/demo.logs.retention.yaml +++ b/config/packages/process/demo.logs.retention.yaml @@ -16,12 +16,12 @@ clever_age_process: file_max_days: 7 tasks: iterate: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [one, two, three] outputs: [log] log: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Item processed level: info diff --git a/config/packages/process/demo.logs.stopped.yaml b/config/packages/process/demo.logs.stopped.yaml index 319061f..01f0a9c 100644 --- a/config/packages/process/demo.logs.stopped.yaml +++ b/config/packages/process/demo.logs.stopped.yaml @@ -11,10 +11,10 @@ clever_age_process: failed_level: warning tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ stop ] options: output: 'value' stop: - service: '@CleverAge\ProcessBundle\Task\StopTask' + task: stop diff --git a/config/packages/process/demo.logs.success_level.yaml b/config/packages/process/demo.logs.success_level.yaml index 8b395fa..09eeeba 100644 --- a/config/packages/process/demo.logs.success_level.yaml +++ b/config/packages/process/demo.logs.success_level.yaml @@ -11,6 +11,6 @@ clever_age_process: success_level: notice tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'value' diff --git a/config/packages/process/demo.mapping_array_target_path.yaml b/config/packages/process/demo.mapping_array_target_path.yaml index 7be787d..692831c 100644 --- a/config/packages/process/demo.mapping_array_target_path.yaml +++ b/config/packages/process/demo.mapping_array_target_path.yaml @@ -11,7 +11,7 @@ clever_age_process: 'contact.email' => 'john@example.com'], with a deprecation logged for "address.city") tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ transform ] options: output: @@ -21,7 +21,7 @@ clever_age_process: email: john@example.com transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: [ debug ] options: transformers: @@ -37,4 +37,4 @@ clever_age_process: code: '[email]' debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.process_launcher.yaml b/config/packages/process/demo.process_launcher.yaml index 9575b51..56f9b6f 100644 --- a/config/packages/process/demo.process_launcher.yaml +++ b/config/packages/process/demo.process_launcher.yaml @@ -8,12 +8,12 @@ clever_age_process: bin/console cleverage:process:execute demo.process_launcher tasks: values: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [one, two, three] outputs: [launch] launch: - service: '@CleverAge\ProcessBundle\Task\Process\ProcessLauncherTask' + task: process_launcher options: process: demo.process_launcher.child max_processes: 2 @@ -27,7 +27,7 @@ clever_age_process: entry_point: log tasks: log: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: level: info message: 'Child process received its input' diff --git a/config/packages/process/demo.rest.get.yaml b/config/packages/process/demo.rest.get.yaml index 868c700..c07e7dd 100644 --- a/config/packages/process/demo.rest.get.yaml +++ b/config/packages/process/demo.rest.get.yaml @@ -28,7 +28,7 @@ clever_age_process: message: 'Le code postal doit être composé de 5 chiffres.' tasks: entry: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request error_strategy: 'stop' options: client: apicarto_ign @@ -37,15 +37,15 @@ clever_age_process: url_parameters: { codePostal: '{{ codePostal }}' } outputs: [json_decode] json_decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [dto] dto: - service: '@CleverAge\ProcessBundle\Task\Serialization\DenormalizerTask' + task: denormalizer options: class: 'App\Dto\Commune[]' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rest.invalid_input.yaml b/config/packages/process/demo.rest.invalid_input.yaml index 1f7eae6..f9d9ad8 100644 --- a/config/packages/process/demo.rest.invalid_input.yaml +++ b/config/packages/process/demo.rest.invalid_input.yaml @@ -8,13 +8,13 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.rest.invalid_input tasks: input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: '/codes-postaux/communes/46800' outputs: [ request ] request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: apicarto_ign url: '/codes-postaux/communes/46800' @@ -22,4 +22,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rest.log_response.yaml b/config/packages/process/demo.rest.log_response.yaml index 3d6d9ea..28919a5 100644 --- a/config/packages/process/demo.rest.log_response.yaml +++ b/config/packages/process/demo.rest.log_response.yaml @@ -8,14 +8,14 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.rest.log_response -vv tasks: input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: url: '/codes-postaux/communes/46800' outputs: [ request ] request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: apicarto_ign url: '/configured/url' @@ -24,4 +24,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rest.post.yaml b/config/packages/process/demo.rest.post.yaml index 44fcca9..7964f58 100644 --- a/config/packages/process/demo.rest.post.yaml +++ b/config/packages/process/demo.rest.post.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request error_strategy: 'stop' options: client: apicarto_ign @@ -23,10 +23,10 @@ clever_age_process: coordinates: [-1.691634,48.104237] outputs: [json_decode] json_decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rest.transport_error.yaml b/config/packages/process/demo.rest.transport_error.yaml index ea20afe..114e759 100644 --- a/config/packages/process/demo.rest.transport_error.yaml +++ b/config/packages/process/demo.rest.transport_error.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.rest.transport_error -v tasks: request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: unreachable url: '/ping' @@ -16,4 +16,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rest.url_parameter_int.yaml b/config/packages/process/demo.rest.url_parameter_int.yaml index 9d69831..fc4dd11 100644 --- a/config/packages/process/demo.rest.url_parameter_int.yaml +++ b/config/packages/process/demo.rest.url_parameter_int.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.rest.url_parameter_int tasks: request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: apicarto_ign url: '/codes-postaux/communes/{codePostal}' @@ -17,4 +17,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rest.valid_client_error.yaml b/config/packages/process/demo.rest.valid_client_error.yaml index 72b149c..9b20e6f 100644 --- a/config/packages/process/demo.rest.valid_client_error.yaml +++ b/config/packages/process/demo.rest.valid_client_error.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.rest.valid_client_error tasks: request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: apicarto_ign url: '/codes-postaux/communes/invalid' @@ -17,4 +17,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.rules.yaml b/config/packages/process/demo.rules.yaml index 853d4e1..50eafbd 100644 --- a/config/packages/process/demo.rules.yaml +++ b/config/packages/process/demo.rules.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - order: @@ -24,7 +24,7 @@ clever_age_process: origin: other outputs: [ transform_value, transform_variable ] transform_value: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: rules: @@ -39,7 +39,7 @@ clever_age_process: set_null: true outputs: [ debug ] transform_variable: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: rules: @@ -56,4 +56,4 @@ clever_age_process: set_null: true outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.sftp_copy.yaml b/config/packages/process/demo.sftp_copy.yaml index becfa5e..2d317e7 100644 --- a/config/packages/process/demo.sftp_copy.yaml +++ b/config/packages/process/demo.sftp_copy.yaml @@ -16,7 +16,7 @@ clever_age_process: target: Foo tasks: copy: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch description: > Download .csv files from remote.storage to local.storage. outputs: aggregate @@ -27,18 +27,18 @@ clever_age_process: remove_source: true ignore_missing: false aggregate: - service: '@CleverAge\ProcessBundle\Task\AggregateIterableTask' + task: aggregate_iterable description: > Aggregate files previously downloaded. Then when all files are downloaded pass to read_local_dir task to read each files one by one. outputs: read_local_dir read_local_dir: - service: '@CleverAge\ProcessBundle\Task\File\FolderBrowserTask' + task: folder_browser outputs: log_local_file options: folder_path: '%local.storage.dir%' log_local_file: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Read file. level: info diff --git a/config/packages/process/demo.sftp_fetch_archive_timeout.yaml b/config/packages/process/demo.sftp_fetch_archive_timeout.yaml index dcb1488..effc116 100644 --- a/config/packages/process/demo.sftp_fetch_archive_timeout.yaml +++ b/config/packages/process/demo.sftp_fetch_archive_timeout.yaml @@ -20,7 +20,7 @@ clever_age_process: bin/console cleverage:process:execute demo.sftp_fetch_archive_timeout -c filesystem:remote.storage.mock tasks: get_file: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch description: > Fetch the source file from `{{ filesystem }}.incoming` (opens + caches connection C_A). Mirrors the client's get_zip; iterable (file_pattern), fans out to treatment and archive_file (LAST). @@ -32,7 +32,7 @@ clever_age_process: ignore_missing: false outputs: [treatment, debug, archive_file] treatment: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: > Long-running treatment placeholder (feeds the idle duration in seconds to the sleep transformer). Must exceed the server idle threshold. @@ -40,16 +40,16 @@ clever_age_process: output: 10 outputs: [treatment_sleep] treatment_sleep: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer description: > Keeps connection C_A idle (generic `sleep` transformer). Dead-end branch. options: transformers: sleep: ~ debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug archive_file: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch description: > Archive the file by reading from `{{ filesystem }}.archive` - a DIFFERENT storage (deduced from the base), so this opens a FRESH connection C_B. Mirrors the client's archive_file. diff --git a/config/packages/process/demo.sftp_purge_input.yaml b/config/packages/process/demo.sftp_purge_input.yaml index a93387a..888945c 100644 --- a/config/packages/process/demo.sftp_purge_input.yaml +++ b/config/packages/process/demo.sftp_purge_input.yaml @@ -15,7 +15,7 @@ clever_age_process: target: Foo tasks: get_files: - service: '@CleverAge\FlysystemProcessBundle\Task\ListContentTask' + task: flysystem_list_content description: > List .csv files from remote.storage. See config/packages/flysystem.yaml to see configured flysystem/storages. @@ -24,13 +24,13 @@ clever_age_process: filesystem: '{{ filesystem }}' file_pattern: '{{ file_pattern }}' get_file_path: - service: '@CleverAge\ProcessBundle\Task\PropertyGetterTask' + task: property_getter description: > Get filepath within flysystem/storage. outputs: remove_input options: property: 'path' remove_input: - service: '@CleverAge\FlysystemProcessBundle\Task\RemoveFileTask' + task: flysystem_remove_file options: filesystem: 'remote.storage' diff --git a/config/packages/process/demo.sftp_purge_pattern.yaml b/config/packages/process/demo.sftp_purge_pattern.yaml index 2edf623..c9c17bc 100644 --- a/config/packages/process/demo.sftp_purge_pattern.yaml +++ b/config/packages/process/demo.sftp_purge_pattern.yaml @@ -15,7 +15,7 @@ clever_age_process: target: Foo tasks: remove_pattern: - service: '@CleverAge\FlysystemProcessBundle\Task\RemoveFileTask' + task: flysystem_remove_file options: filesystem: '{{ filesystem }}' file_pattern: '{{ file_pattern }}' diff --git a/config/packages/process/demo.sftp_stale_connection.yaml b/config/packages/process/demo.sftp_stale_connection.yaml index 0cbf89a..f4aa3d6 100644 --- a/config/packages/process/demo.sftp_stale_connection.yaml +++ b/config/packages/process/demo.sftp_stale_connection.yaml @@ -16,7 +16,7 @@ clever_age_process: bin/console cleverage:process:execute demo.sftp_stale_connection -c filesystem:remote.storage.short_timeout tasks: get_file: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch description: > Fetch the source file from `{{ filesystem }}.incoming` (opens + caches the connection). Iterable (file_pattern); fans out to treatment and archive_file (archive_file LAST). @@ -28,7 +28,7 @@ clever_age_process: ignore_missing: false outputs: [treatment, debug, archive_file] treatment: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: > Long-running treatment placeholder (idle duration in seconds). Must exceed the server idle threshold (sftp-short drops idle clients after ~6s). @@ -36,16 +36,16 @@ clever_age_process: output: 10 outputs: [treatment_sleep] treatment_sleep: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer description: > Keeps the cached connection idle (generic `sleep` transformer). Dead-end branch. options: transformers: sleep: ~ debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug archive_file: - service: '@CleverAge\FlysystemProcessBundle\Task\FileFetchTask' + task: flysystem_file_fetch description: > Archive by reading from `{{ filesystem }}.archive` - a DIFFERENT storage (deduced from the base), so this opens a FRESH connection. diff --git a/config/packages/process/demo.soap.call_failure.yaml b/config/packages/process/demo.soap.call_failure.yaml index 714437b..a8a2d5c 100644 --- a/config/packages/process/demo.soap.call_failure.yaml +++ b/config/packages/process/demo.soap.call_failure.yaml @@ -12,14 +12,14 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: sCountryISOCode: 'FR' outputs: [request] request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request error_strategy: 'stop' options: client: unreachable @@ -27,7 +27,7 @@ clever_age_process: outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug demo.soap.call_failure_skip: description: > @@ -41,14 +41,14 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: sCountryISOCode: 'FR' outputs: [request] request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request error_strategy: 'skip' options: client: unreachable @@ -57,7 +57,7 @@ clever_age_process: error_outputs: [debug_error] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug debug_error: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.soap.client_headers.yaml b/config/packages/process/demo.soap.client_headers.yaml index bf3ec11..55e5cc9 100644 --- a/config/packages/process/demo.soap.client_headers.yaml +++ b/config/packages/process/demo.soap.client_headers.yaml @@ -9,7 +9,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.soap.client_headers tasks: reset: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request description: Reset the WireMock request journal options: client: wiremock_admin @@ -18,28 +18,28 @@ clever_age_process: outputs: [ input ] input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 1 outputs: [ request ] request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request options: client: wiremock method: 'GetBook' outputs: [ no_input ] no_input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: The next request does not take the previous output as input options: output: { } outputs: [ count ] count: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request description: Count the SOAP requests sent with the ClientToken header, must output {"count":1} options: client: wiremock_admin @@ -53,4 +53,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.soap.false_result.yaml b/config/packages/process/demo.soap.false_result.yaml index bb7d00b..9a1f04c 100644 --- a/config/packages/process/demo.soap.false_result.yaml +++ b/config/packages/process/demo.soap.false_result.yaml @@ -8,18 +8,18 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.soap.false_result tasks: input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 1 outputs: [ request ] request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request options: client: wiremock method: 'IsAvailable' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.soap.fault_without_exceptions.yaml b/config/packages/process/demo.soap.fault_without_exceptions.yaml index 4ae96d4..3177cd1 100644 --- a/config/packages/process/demo.soap.fault_without_exceptions.yaml +++ b/config/packages/process/demo.soap.fault_without_exceptions.yaml @@ -8,11 +8,11 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.soap.fault_without_exceptions tasks: request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request options: client: wiremock_no_exceptions method: 'Fail' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.soap.headers_leak.yaml b/config/packages/process/demo.soap.headers_leak.yaml index 3c6e8c8..2467416 100644 --- a/config/packages/process/demo.soap.headers_leak.yaml +++ b/config/packages/process/demo.soap.headers_leak.yaml @@ -9,7 +9,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.soap.headers_leak tasks: reset: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request description: Reset the WireMock request journal options: client: wiremock_admin @@ -18,14 +18,14 @@ clever_age_process: outputs: [ input ] input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 1 outputs: [ request ] request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request options: client: wiremock method: 'GetBook' @@ -36,14 +36,14 @@ clever_age_process: outputs: [ transformer_input ] transformer_input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 2 outputs: [ transformer ] transformer: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: soap_request: @@ -52,14 +52,14 @@ clever_age_process: outputs: [ no_input ] no_input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: The next request does not take the previous output as input options: output: { } outputs: [ count ] count: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request description: Count the SOAP requests sent with the TaskToken header, must output {"count":1} options: client: wiremock_admin @@ -73,4 +73,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.soap.invalid_input.yaml b/config/packages/process/demo.soap.invalid_input.yaml index b8eb82c..309fc59 100644 --- a/config/packages/process/demo.soap.invalid_input.yaml +++ b/config/packages/process/demo.soap.invalid_input.yaml @@ -8,17 +8,17 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.soap.invalid_input tasks: input: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'GetBook' outputs: [ request ] request: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request options: client: wiremock method: 'GetBook' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.soap.yaml b/config/packages/process/demo.soap.yaml index d546265..70ceccd 100644 --- a/config/packages/process/demo.soap.yaml +++ b/config/packages/process/demo.soap.yaml @@ -11,14 +11,14 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\SoapProcessBundle\Task\RequestTask' + task: soap_request error_strategy: 'stop' options: client: oorsprong_countryinfo method: 'FullCountryInfoAllCountries' outputs: [filter_europe] filter_europe: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: property_accessor: @@ -29,7 +29,7 @@ clever_age_process: sContinentCode: 'EU' outputs: [phone_code, iso_code] phone_code: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: array_map: @@ -44,7 +44,7 @@ clever_age_process: code: '[sCountryFlag]' outputs: [debug] iso_code: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: array_map: @@ -59,4 +59,4 @@ clever_age_process: code: '[sName]' outputs: [debug] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.stopwatch.yaml b/config/packages/process/demo.stopwatch.yaml index 825a10f..37c9264 100644 --- a/config/packages/process/demo.stopwatch.yaml +++ b/config/packages/process/demo.stopwatch.yaml @@ -11,4 +11,4 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\Debug\StopwatchTask' + task: stopwatch diff --git a/config/packages/process/demo.string.preg_filter.yaml b/config/packages/process/demo.string.preg_filter.yaml index ad49e1e..4454566 100644 --- a/config/packages/process/demo.string.preg_filter.yaml +++ b/config/packages/process/demo.string.preg_filter.yaml @@ -12,13 +12,13 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ single_pattern, multiple_patterns ] options: output: '28/09/2026' single_pattern: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -27,7 +27,7 @@ clever_age_process: replacement: '$3-$2-$1' multiple_patterns: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -36,4 +36,4 @@ clever_age_process: replacement: [ '.', 'MMXXVI' ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.string.preg_match.yaml b/config/packages/process/demo.string.preg_match.yaml index 14e0667..13b9427 100644 --- a/config/packages/process/demo.string.preg_match.yaml +++ b/config/packages/process/demo.string.preg_match.yaml @@ -11,13 +11,13 @@ clever_age_process: target: Foo tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: preg_match options: output: 'foobarbaz' preg_match: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: debug options: transformers: @@ -28,4 +28,4 @@ clever_age_process: property_path: '[2]' debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.tasks_edge.yaml b/config/packages/process/demo.tasks_edge.yaml index 7b9541b..8294b6b 100644 --- a/config/packages/process/demo.tasks_edge.yaml +++ b/config/packages/process/demo.tasks_edge.yaml @@ -7,12 +7,12 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.tasks_edge.advanced_stat_counter -v tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [a, b, c] outputs: [ stats ] stats: - service: '@CleverAge\ProcessBundle\Task\Reporting\AdvancedStatCounterTask' + task: advanced_stat_counter options: show_every: 1 @@ -23,17 +23,17 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.tasks_edge.iterable_batch_null tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: [a, b, c] outputs: [ batch ] batch: - service: '@CleverAge\ProcessBundle\Task\IterableBatchTask' + task: iterable_batch options: batch_count: ~ outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug demo.tasks_edge.condition_scalar: description: > @@ -42,12 +42,12 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.tasks_edge.condition_scalar tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: [a, b] outputs: [ filter ] filter: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: array_filter: @@ -56,7 +56,7 @@ clever_age_process: '': a outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug demo.tasks_edge.column_aggregator_null: description: > @@ -65,14 +65,14 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.tasks_edge.column_aggregator_null tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: { a: x, b: ~ } outputs: [ aggregate ] aggregate: - service: '@CleverAge\ProcessBundle\Task\ColumnAggregatorTask' + task: column_aggregator options: columns: [a, b] outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.transformer.yaml b/config/packages/process/demo.transformer.yaml index 6216cb2..4a04aea 100644 --- a/config/packages/process/demo.transformer.yaml +++ b/config/packages/process/demo.transformer.yaml @@ -11,7 +11,7 @@ clever_age_process: target: Foo tasks: extract: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: id: 123 @@ -20,7 +20,7 @@ clever_age_process: outputs: [ transform ] transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: mapping: @@ -74,9 +74,9 @@ clever_age_process: outputs: [ load, log ] log: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Transformed level: info load: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.transformer_list.yaml b/config/packages/process/demo.transformer_list.yaml index e4a8f91..363ba3d 100644 --- a/config/packages/process/demo.transformer_list.yaml +++ b/config/packages/process/demo.transformer_list.yaml @@ -20,7 +20,7 @@ clever_age_process: (outputs ['tags' => ['3', '2', '1'], 'name' => 'John']) tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output outputs: [ transform ] options: output: @@ -28,7 +28,7 @@ clever_age_process: name: ' John ' transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer outputs: [ debug ] options: transformers: @@ -53,4 +53,4 @@ clever_age_process: tag: b debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.transformers_edge.cached.yaml b/config/packages/process/demo.transformers_edge.cached.yaml index 0adad90..bed1022 100644 --- a/config/packages/process/demo.transformers_edge.cached.yaml +++ b/config/packages/process/demo.transformers_edge.cached.yaml @@ -7,12 +7,12 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.transformers_edge.cached tasks: extract: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 42 outputs: [ transform ] transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: cached: @@ -25,4 +25,4 @@ clever_age_process: type: string outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.transformers_edge.slugify.yaml b/config/packages/process/demo.transformers_edge.slugify.yaml index 5740a9e..da524a4 100644 --- a/config/packages/process/demo.transformers_edge.slugify.yaml +++ b/config/packages/process/demo.transformers_edge.slugify.yaml @@ -7,16 +7,16 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.transformers_edge.slugify tasks: extract: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'Hélène Dupont' outputs: [ transform ] transform: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: slugify: transliterator: 'Not-A-Real-Transliterator' outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.ui.entity_manager_clear.yaml b/config/packages/process/demo.ui.entity_manager_clear.yaml index 52c136c..7ae076b 100644 --- a/config/packages/process/demo.ui.entity_manager_clear.yaml +++ b/config/packages/process/demo.ui.entity_manager_clear.yaml @@ -13,21 +13,21 @@ clever_age_process: target: Bar tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'before clear' outputs: [log_before] log_before: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Log before the clear level: warning outputs: [clear] clear: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\ClearEntityManagerTask' + task: doctrine_clear_entity_manager outputs: [log_after] log_after: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Log after the clear level: warning diff --git a/config/packages/process/demo.ui.entity_manager_closed.yaml b/config/packages/process/demo.ui.entity_manager_closed.yaml index ccf7f4e..df3d1a2 100644 --- a/config/packages/process/demo.ui.entity_manager_closed.yaml +++ b/config/packages/process/demo.ui.entity_manager_closed.yaml @@ -15,29 +15,29 @@ clever_age_process: target: Bar tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: firstname: Too lastname: 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx' outputs: [log_before] log_before: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Log before the failing flush level: warning outputs: [denormalize] denormalize: - service: '@CleverAge\ProcessBundle\Task\Serialization\DenormalizerTask' + task: denormalizer options: class: App\Entity\Author outputs: [save] save: - service: '@CleverAge\DoctrineProcessBundle\Task\EntityManager\DoctrineWriterTask' + task: doctrine_writer error_strategy: skip outputs: [log_after] log_after: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Log after the failing flush level: warning diff --git a/config/packages/process/demo.ui.notification.yaml b/config/packages/process/demo.ui.notification.yaml index b433549..cd6020a 100644 --- a/config/packages/process/demo.ui.notification.yaml +++ b/config/packages/process/demo.ui.notification.yaml @@ -16,12 +16,12 @@ clever_age_process: enabled: true tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: 'data' outputs: [log] log: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Warning counted in the report of the process execution level: warning diff --git a/config/packages/process/demo.ui.notification_failing.yaml b/config/packages/process/demo.ui.notification_failing.yaml index 61562c4..a84c1f6 100644 --- a/config/packages/process/demo.ui.notification_failing.yaml +++ b/config/packages/process/demo.ui.notification_failing.yaml @@ -16,4 +16,4 @@ clever_age_process: enabled: true tasks: entry: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output diff --git a/config/packages/process/demo.ui.stop.yaml b/config/packages/process/demo.ui.stop.yaml index f1e7edd..7bfddae 100644 --- a/config/packages/process/demo.ui.stop.yaml +++ b/config/packages/process/demo.ui.stop.yaml @@ -15,7 +15,7 @@ clever_age_process: target: Bar tasks: iterate: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: # 60 items: the number of microseconds to wait for each one output: [1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, @@ -26,14 +26,14 @@ clever_age_process: 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000, 1000000] outputs: [wait] wait: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: callback: callback: usleep outputs: [log] log: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Item processed level: info diff --git a/config/packages/process/demo.upload_and_run.yaml b/config/packages/process/demo.upload_and_run.yaml index dcdda94..eeca149 100644 --- a/config/packages/process/demo.upload_and_run.yaml +++ b/config/packages/process/demo.upload_and_run.yaml @@ -31,22 +31,22 @@ clever_age_process: message: delimiter context must be , or ;. {{ value }} given. tasks: entrypoint: # Add log info to describe which file is reading - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Read file level: info context: [ 'input' ] outputs: [ read ] read: - service: '@CleverAge\ProcessBundle\Task\File\Csv\InputCsvReaderTask' + task: input_csv_reader outputs: [ log_line, dump ] options: delimiter: '{{ delimiter }}' ## delimiter is contextualized you must add -c delimiter:";" on console execute log_line: - service: '@CleverAge\ProcessBundle\Task\Reporting\LoggerTask' + task: logger options: message: Read line level: info context: [ 'input' ] dump: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.wiremock.authentication.yaml b/config/packages/process/demo.wiremock.authentication.yaml index c188fe5..5da4395 100644 --- a/config/packages/process/demo.wiremock.authentication.yaml +++ b/config/packages/process/demo.wiremock.authentication.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.authentication tasks: requests: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - headers: { } @@ -16,7 +16,7 @@ clever_age_process: outputs: [ request ] request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request error_strategy: skip options: client: wiremock @@ -26,15 +26,15 @@ clever_age_process: error_outputs: [ error ] decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug error: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug description: Receives the response body of the requests in error (error_outputs) diff --git a/config/packages/process/demo.wiremock.error_codes.yaml b/config/packages/process/demo.wiremock.error_codes.yaml index 66f616a..42ef6d6 100644 --- a/config/packages/process/demo.wiremock.error_codes.yaml +++ b/config/packages/process/demo.wiremock.error_codes.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.error_codes tasks: ids: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - url_parameters: { id: '1' } @@ -18,7 +18,7 @@ clever_age_process: outputs: [ request ] request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request error_strategy: skip options: client: wiremock @@ -28,15 +28,15 @@ clever_age_process: error_outputs: [ error ] decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug error: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug description: Receives the response body of the requests in error (error_outputs) diff --git a/config/packages/process/demo.wiremock.fault.yaml b/config/packages/process/demo.wiremock.fault.yaml index f353b33..533c76d 100644 --- a/config/packages/process/demo.wiremock.fault.yaml +++ b/config/packages/process/demo.wiremock.fault.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.fault -v tasks: request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: wiremock url: '/unstable' @@ -16,4 +16,4 @@ clever_age_process: outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.wiremock.get_json.yaml b/config/packages/process/demo.wiremock.get_json.yaml index 1d62087..bd6aa0d 100644 --- a/config/packages/process/demo.wiremock.get_json.yaml +++ b/config/packages/process/demo.wiremock.get_json.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.get_json tasks: request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: wiremock url: '/books' @@ -16,15 +16,15 @@ clever_age_process: outputs: [ decode ] decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [ iterate ] iterate: - service: '@CleverAge\ProcessBundle\Task\InputIteratorTask' + task: input_iterator outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.wiremock.path_templating.yaml b/config/packages/process/demo.wiremock.path_templating.yaml index 9f1da0b..9e8cd7a 100644 --- a/config/packages/process/demo.wiremock.path_templating.yaml +++ b/config/packages/process/demo.wiremock.path_templating.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.path_templating tasks: ids: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - url_parameters: { id: '1' } @@ -16,7 +16,7 @@ clever_age_process: outputs: [ request ] request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: wiremock url: '/books/{id}' @@ -24,11 +24,11 @@ clever_age_process: outputs: [ decode ] decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/config/packages/process/demo.wiremock.post_json.yaml b/config/packages/process/demo.wiremock.post_json.yaml index a60bb3a..4f81631 100644 --- a/config/packages/process/demo.wiremock.post_json.yaml +++ b/config/packages/process/demo.wiremock.post_json.yaml @@ -9,7 +9,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.post_json tasks: books: - service: '@CleverAge\ProcessBundle\Task\ConstantIterableOutputTask' + task: constant_iterable_output options: output: - data: { title: 'Carrie' } @@ -17,7 +17,7 @@ clever_age_process: outputs: [ request ] request: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request error_strategy: skip options: client: wiremock @@ -28,15 +28,15 @@ clever_age_process: error_outputs: [ error ] decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug error: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug description: Receives the response body of the requests in error (error_outputs) diff --git a/config/packages/process/demo.wiremock.verify_requests.yaml b/config/packages/process/demo.wiremock.verify_requests.yaml index bc541bd..a03ccb5 100644 --- a/config/packages/process/demo.wiremock.verify_requests.yaml +++ b/config/packages/process/demo.wiremock.verify_requests.yaml @@ -8,7 +8,7 @@ clever_age_process: Ex: bin/console cleverage:process:execute demo.wiremock.verify_requests tasks: reset: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request description: Reset the request journal (DELETE /__admin/requests) options: client: wiremock_admin @@ -17,14 +17,14 @@ clever_age_process: outputs: [ no_input_1 ] no_input_1: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output description: The next request does not take the previous response as input options: output: { } outputs: [ books ] books: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: wiremock url: '/books' @@ -32,13 +32,13 @@ clever_age_process: outputs: [ no_input_2 ] no_input_2: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: { } outputs: [ book ] book: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request options: client: wiremock url: '/books/1' @@ -46,13 +46,13 @@ clever_age_process: outputs: [ no_input_3 ] no_input_3: - service: '@CleverAge\ProcessBundle\Task\ConstantOutputTask' + task: constant_output options: output: { } outputs: [ count ] count: - service: '@CleverAge\RestProcessBundle\Task\RequestTask' + task: rest_request description: Count the matching requests (POST /__admin/requests/count), outputs {"count":2} options: client: wiremock_admin @@ -64,11 +64,11 @@ clever_age_process: outputs: [ decode ] decode: - service: '@CleverAge\ProcessBundle\Task\TransformerTask' + task: transformer options: transformers: json_decode: ~ outputs: [ debug ] debug: - service: '@CleverAge\ProcessBundle\Task\Debug\DebugTask' + task: debug diff --git a/docs/reference/tasks/_template.md b/docs/reference/tasks/_template.md index ed1d4a5..6f293e8 100644 --- a/docs/reference/tasks/_template.md +++ b/docs/reference/tasks/_template.md @@ -37,7 +37,7 @@ _YAML samples and explanations_ ```yaml # Task configuration level code: - service: '@service_ref' + task: task_code options: a: 1 b: 2