Chaque commande dit quelle version de la règle l'a calculée

Objectif Savoir, des mois plus tard, quelle règle de port a calculé chaque commande.

Le port est calculé par un script Kotlin que fournit l'opérateur du hub. En décembre, il est offert dès 150,00. Au 1er janvier, dès 200,00. L'opérateur remplace le script.

deux commandes de 172,50: port offert en décembre, payé en janvier;
chaque run nomme la version de la règle par son empreinte;
chaque commande nomme son run: on remonte de la commande à la règle avec lm.

lumnik Open
Ventes
Audit
Connector
Entity

manifests/shipping-fee-v1.kts

// Operator-provided: the shipping fee of an order. Free shipping from 150.00 of goods.@Suppress("UNCHECKED_CAST")val cells = bindings["cells"] as MutableMap<String, Any?>val total = (cells["goods_total"] as String).toBigDecimal()cells["shipping_fee"] = if (total >= "150.00".toBigDecimal()) "0.00" else "12.90"

$ lm hook scripts
NAME                SIZE  SHA256
shipping-fee-b.kts  316   23ba31c1b1827ff86228f4f7f36ffd2b73b7ab77ef155598bf05ef12c4b1273e

orders-2025-12.csv

order_no;order_date;customer;goods_total
CMD-2401;2025-12-03;Durand;89.00
CMD-2402;2025-12-09;Morel;172.50
CMD-2403;2025-12-15;Nguyen;240.00
CMD-2404;2025-12-22;Faure;150.00

manifests/10-orders.yaml

apiVersion: connectors.lumnik.io/v1kind: Connectormetadata:  name: scenario-shipping-b  connector_type: csv-file  scopes: [sales-b]spec:  transport:    kind: local    path: /tmp/lumnik-scenario/shipping-rule-changed/b/orders-*.csv   # one export per month  parser:    delimiter: ";"  after_process: none  mapping:    cell:      - kotlin:          script: hooks:shipping-fee-b.kts   # the operator's rule, in the hub's hooks directory

$ lm apply -f 10-orders.yaml
Applied connector "scenario-shipping-b" — 1 endpoint

$ lm connector run scenario-shipping-b
run scheduled: 1018cd06-0820-4a9c-80f3-b0fea9bcf222

$ lm run get 1018cd06-0820-4a9c-80f3-b0fea9bcf222
ID        CONNECTOR            ENDPOINT  STATUS     IN  OUT  SKIPPED  DEAD-LETTERS  STARTED           ENDED
1018cd06  scenario-shipping-b  default   Completed  4   4    0        0             2026-11-03 15:40  2026-11-03 15:40
• script hooks:shipping-fee-b.kts  sha256 23ba31c1b1827ff86228f4f7f36ffd2b73b7ab77ef155598bf05ef12c4b1273e

manifests/shipping-fee-v2.kts

// Operator-provided: the shipping fee of an order. Free shipping from 200.00 of goods (from 1 January).@Suppress("UNCHECKED_CAST")val cells = bindings["cells"] as MutableMap<String, Any?>val total = (cells["goods_total"] as String).toBigDecimal()cells["shipping_fee"] = if (total >= "200.00".toBigDecimal()) "0.00" else "12.90"

$ lm hook scripts
NAME                SIZE  SHA256
shipping-fee-b.kts  333   c1c59e5c7b81302d5a284c9c722ca8cacaca0fe859c8ae1c393cd1d54a1ad9ad

orders-2026-01.csv

order_no;order_date;customer;goods_total
CMD-2501;2026-01-05;Roux;172.50
CMD-2502;2026-01-12;Garnier;199.99
CMD-2503;2026-01-19;Durand;215.00

$ lm connector run scenario-shipping-b
run scheduled: 94dfe0ed-ec87-4eb6-ae7c-df9dd2d3ffc2

$ lm run get 94dfe0ed-ec87-4eb6-ae7c-df9dd2d3ffc2
ID        CONNECTOR            ENDPOINT  STATUS     IN  OUT  SKIPPED  DEAD-LETTERS  STARTED           ENDED
94dfe0ed  scenario-shipping-b  default   Completed  3   3    0        0             2026-11-03 15:40  2026-11-03 15:40
• 1 file(s) unchanged since they were last read — not read again
• script hooks:shipping-fee-b.kts  sha256 c1c59e5c7b81302d5a284c9c722ca8cacaca0fe859c8ae1c393cd1d54a1ad9ad

manifests/20-shipped-order.yaml

kind: Entityname: shipped_order_blabel: Commande expédiéedescription: "An order with the shipping fee the operator's rule computed, and the run that wrote it."match: [order_no]scopes: [sales-b]columns:  order_no: { label: "Commande" }  order_date: { label: "Date" }  customer: { label: "Client" }  goods_total: { label: "Marchandises" }  shipping_fee: { label: "Port" }  run_id: { label: "Run" }sources:  - table: t_scenario_shipping_b    map: { order_no: order_no, order_date: order_date, customer: customer, goods_total: goods_total,           shipping_fee: shipping_fee, _run_id: run_id }   # _run_id: the run that wrote the row

$ lm entity apply -f 20-shipped-order.yaml
Applied entity "shipped_order_b" → connector."v_shipped_order_b"

$ lm entity get shipped_order_b
ORDER_NO  ORDER_DATE  CUSTOMER  GOODS_TOTAL  SHIPPING_FEE  RUN_ID                                _CONFLICTS
CMD-2401  2025-12-03  Durand    89.00        12.90         1018cd06-0820-4a9c-80f3-b0fea9bcf222  {}
CMD-2402  2025-12-09  Morel     172.50       0.00          1018cd06-0820-4a9c-80f3-b0fea9bcf222  {}
CMD-2403  2025-12-15  Nguyen    240.00       0.00          1018cd06-0820-4a9c-80f3-b0fea9bcf222  {}
CMD-2404  2025-12-22  Faure     150.00       0.00          1018cd06-0820-4a9c-80f3-b0fea9bcf222  {}
CMD-2501  2026-01-05  Roux      172.50       12.90         94dfe0ed-ec87-4eb6-ae7c-df9dd2d3ffc2  {}
CMD-2502  2026-01-12  Garnier   199.99       12.90         94dfe0ed-ec87-4eb6-ae7c-df9dd2d3ffc2  {}
CMD-2503  2026-01-19  Durand    215.00       0.00          94dfe0ed-ec87-4eb6-ae7c-df9dd2d3ffc2  {}

$ lm run get 1018cd06-0820-4a9c-80f3-b0fea9bcf222
ID        CONNECTOR            ENDPOINT  STATUS     IN  OUT  SKIPPED  DEAD-LETTERS  STARTED           ENDED
1018cd06  scenario-shipping-b  default   Completed  4   4    0        0             2026-11-03 15:40  2026-11-03 15:40
• script hooks:shipping-fee-b.kts  sha256 23ba31c1b1827ff86228f4f7f36ffd2b73b7ab77ef155598bf05ef12c4b1273e

Limites

Le run liste les versions qu'il a appliquées, pas quelles lignes sont passées par laquelle. Un script remplacé pendant un run laisse ses lignes sous les deux versions.
L'empreinte identifie un texte. Garder les versions du script reste le travail de l'opérateur.
Commandes synthétiques.

Ventes · audit

Le port suit une règle de l'opérateur.

Elle change au 1er janvier.

Offert dès 150,00, puis dès 200,00

La question

Pourquoi ce port, sur cette commande?

172,50 en décembre: port offert.
172,50 en janvier: port payé.

Ce qui n'est pas modifié

Le connecteur reste le même.

Il nomme la règle, il ne la contient pas.
L'opérateur remplace le fichier.

Le piège

Une règle remplacée ne laisse pas de trace.

Même nom de fichier.
On ne sait plus laquelle a tourné.

Ce qu'il a fallu écrire

_run_id: run_id

Une ligne.

Chaque commande nomme son run.
Chaque run nomme sa version de la règle.
Deux manifestes, 34 lignes.

La réponse

Deux runs, deux empreintes.

Décembre: la version 1.
Janvier: la version 2.

La limite

L'empreinte nomme un texte.

Garder les versions du script reste le travail de l'opérateur.

Essayer

Le scénario se rejoue en local.

Chaque étape est publiée avec sa sortie.

Ce scénario tourne sur lumnik Open, gratuit et open source.

Essayer lumnik Open →