Yeah that was the plan. I was using "schedule" in a bit looser sense.
My thought was that a Raspberry pi notices the flow and triggers an Apache airflow dataset every 10 sec or so while it's still flowing. DAGs which consume that "dataset" (a misnomer in this case) will run. Flow stops, DAGs stop.