Wenjun Ruan
Wenjun Ruan
+1, I added to DSIP
> Hey, I'd like to take on this task. Has it already been started Not started, it's better to provide a design.
> [@ruanwenjun](https://github.com/ruanwenjun) Hello, I have a design question. Why do ITaskExecutor and IWorkflowExecutionRunnable each require their own EventBus? > > In systems I've observed, a component typically uses a single...
Each Job/Workflow has its own event bus is common design at these kind of system, it make event management easy, at yarn each RMApp also has its own event queue....
The metadata event belongs to workflow/project/datasource, you can only add one event bus in API module, once the workflow online/offline/update, project create/delete, datasource create/delete/update you can produce the event.
Please use `AdHocDataSourceClient`, you can find the related code in dev.
You should have a design and poc code before submit pr.
A task is executed only if all upstream edges are reachable, in your dag, the switch doesn't want `echo_teriteri` executed.
> > A task is executed only if all upstream edges are reachable, in your dag, the switch doesn't want `echo_teriteri` executed. > > You're correct that in this DAG,...