Integrations map

Package framework/integration/

Subpackage	Purpose
ui/	Streamlit launcher + DRTML forms
airflow/	DAG discover, run_task, orchestrator params
local/	CLI runner without Airflow
ray/	ensure_ray_connected
env.py	env helpers / DSN mapping

Steps do not import integration/* (except thin hooks that call framework APIs).

Flow

User / Scheduler
  → integration (params overlay + RunContext)
  → processing.dispatch
  → …

Worker transport (pool/Ray submit) lives in processing/.../parallel/backends/, not in integration.