File indexing completed on 2026-08-12 09:36:21
0001 """STF datataking workflow episodes.
0002
0003 The default testbed exercise: agent messages recorded live through the
0004 shared testbed mapping, no workload join — the workflow's example
0005 agents submit nothing.
0006 """
0007
0008 from .common import TestbedEpisodeDefinition
0009
0010
0011 class StfDatatakingEpisodes(TestbedEpisodeDefinition):
0012 workflow_name = 'stf_datataking'
0013 completion_deadline_seconds = 60
0014
0015 def summary(self, context):
0016 return {'run_id': (context.last_message or {}).get('run_id')}