Outlet(processors: Union[callable, List[callable]] = None)¶
Abstract class representing an output of the data stream.
push(self, records: List[Record], update: da.Update)¶
Push received data.
Override this method to define how this outlet will handle received data.
Record]) – List of records generated by inlets. Each top-level element of this array corresponds to one inlet that successfully returned data. Note that inlets could return arrays too, making this a nested array.
Update) – Update object representing the particular Link transfer.
Wrapper around on_start call that will ensure it only gets executed once.
Called once per outlet just before the governing planner is about to start.
Override this method to provide starting functionality on this outlet.
Wrapper around on_shutdown call that will ensure it only gets executed once.
Called once per outlet just after the governing planner has shutdown.
Override this method to provide shutdown functionality on this outlet.