Agent-level setting that determines how event history is loaded.
ALL: the entire history, across all agents and tasks, is shown
UPSTREAM: only events that EITHER involve the current agent OR are upstream of the current task in the flow DAG are shown
CURRENT_AGENT: only events from the current agent, across all tasks
CURRENT_TASK: only events from the current task, across all agents
a = Agent(history_visibility='UPSTREAM')
This will probably require some finessing to get right. In particular, taking a task result, modifying it, then passing that data to another task could interrupt the upstream chain (the downstream task can't detect the upstream) and we'll probably want a way to "load" extra history.
Note: ALL history is the default, which is different than the default on the 0.9 branch so far (but mirrors 0.8 behavior)
Agent-level setting that determines how event history is loaded.
ALL: the entire history, across all agents and tasks, is shownUPSTREAM: only events that EITHER involve the current agent OR are upstream of the current task in the flow DAG are shownCURRENT_AGENT: only events from the current agent, across all tasksCURRENT_TASK: only events from the current task, across all agentsThis will probably require some finessing to get right. In particular, taking a task result, modifying it, then passing that data to another task could interrupt the upstream chain (the downstream task can't detect the upstream) and we'll probably want a way to "load" extra history.
Note:
ALLhistory is the default, which is different than the default on the 0.9 branch so far (but mirrors 0.8 behavior)