simpleflow
simpleflow copied to clipboard
botify-labs
Python library for dataflow programming.
the `for child in psutil.Process().children():` loop body needs protection against NoSuchProcess.
Somehow low priority but I have a hard time wrapping my head around some parts of simpleflow, and I believe in good docs. I will work on that on my...
Today, we have canvas to create dependencies through groups and chain. The problem is that we don't have the possibility to give them multiple dependencies for one of them. Ex...
If I have a task class such as this one: @activity.with_attributes(task_list='quickstart', version='example') class Delay(object): .... And then try to build up a Group of these such as: c1 = canvas.Chain(...
I would like to create a child/sub-Workflow that I can 'submit()' to a parent Workflow, but currently this is not supported. So a Workflow 'activity' can be submitted via this...
Centralizing logging in a single process would avoid having overlapping lines in the log output. Note that the other "canonical" way to do that is to _not_ log to stdout/a...
``` [process=Process-1, pid=31432]: spawn() pid=31432 heartbeat=60 [process=Process-1:3, pid=483]: process_task() pid=483 [process=Process-1:3, pid=483]: ActivityWorker.process() pid=483 [process=Process-1, pid=31432]: heartbeating for pid=483 (token=AA..==) [process=Process-1:3, pid=483]: entering state completing: complete(args=(u'AA..==', '2'), kwargs={}) [process=Process-1, pid=31432]:...
Hi, We noticed if we start simpleflow like follows: ``` simpleflow decider.start --domain testdomain --task-list test examples.basic.BasicWorkflow simpleflow worker.start --domain testdomain --task-list quickstart examples.basic.BasicWorkflow ``` ... then the **new workflow...
Discussed a bit in #129, I often run flake8 manually and @ybastide too, so let's have this in Travis and fix obvious problems right away. I usually like it except...
I was going through the example to try out Simpleflow. I noticed that after a few execution I had about 50-80 processes running Activity Poller and Decision Poller. I thought...
