code: def schema_complete():
          
          return Schema({
              'stage': And(str, len),
              'status': And(str, lambda s: s in ['started', 'succeeded', 'failed']),
              Optional('events', default=[]): And(len, [CollectorStage.schema_event_items()])
          })
docs: Schema for data in CollectorStage.