The logistics layer EU supply chain compliance is missing.

// koto7 — DPPPassportLifecycleWorkflow
// A single workflow that survives years of
// ownership transfer, certification, and end-of-life
@workflow.defn
class DPPPassportLifecycleWorkflow:
  @workflow.run
  async def run(self, passport_id: str) -> None:
    while True:
      signal = await workflow.wait_for_signal([
        "JobCustodyRecorded",
        "CertificationReceived",
        "OwnershipTransferred",
        "DisposalEvent",
      ])
      # Update passport state durably
      await workflow.execute_activity(
        update_passport_state,
        args=[passport_id, signal],
        start_to_close_timeout=timedelta(seconds=30),
      )
      # Mint to public chain on certification
      if signal.type == "CertificationReceived":
        await workflow.execute_activity(
          mint_state_hash,
          start_to_close_timeout=timedelta(minutes=5),
        )
      # Passport survived years. continueAsNew to
# stay within Temporal history limits.
      if workflow.info().get_current_history_length() > 9000:
        workflow.continue_as_new(args=[passport_id])