|
|
|
|
@ -36,8 +36,8 @@ La pipeline du projet *Actes princiers* possède deux points d'entrée :
|
|
|
|
|
- `parse_json_collection`, qui correspond au traitement sur le datacatalog `bourbon_json` vers le datacatlog `bourbon_jsonoutput`
|
|
|
|
|
- La fonction appelée depuis `nodes.py` est `parse_json_collection()`.
|
|
|
|
|
|
|
|
|
|
```py
|
|
|
|
|
def create_pipeline(**kwargs) -> Pipeline:
|
|
|
|
|
.. code-block:: python
|
|
|
|
|
def create_pipeline(**kwargs) -> Pipeline:
|
|
|
|
|
return pipeline(
|
|
|
|
|
[
|
|
|
|
|
node(
|
|
|
|
|
@ -52,7 +52,6 @@ def create_pipeline(**kwargs) -> Pipeline:
|
|
|
|
|
outputs="bourbon_jsonoutput",
|
|
|
|
|
name="bourbon_json_ds_collection",
|
|
|
|
|
),
|
|
|
|
|
```
|
|
|
|
|
|
|
|
|
|
`nodes.py`
|
|
|
|
|
--------
|
|
|
|
|
|