Pre-release
This release is a pre-release and may not be stable for production use.
pypushflow
A task scheduler for cyclic and acyclic graphs
Install
python -m pip install pypushflow[mx]
Use the mx option for installation at MX beamlines.
Run tests
python -m pip install pypushflow[test]
pytest
Getting started
import logging
from pypushflow.Workflow import Workflow
from pypushflow.StopActor import StopActor
from pypushflow.StartActor import StartActor
from pypushflow.PythonActor import PythonActor
from pypushflow.ThreadCounter import ThreadCounter
class MyWorkflow(Workflow):
"""
Workflow containing one start actor,
one python actor and one stop actor.
"""
def __init__(self, name):
super().__init__(name, level=logging.DEBUG)
ctr = ThreadCounter(parent=self)
self.startActor = StartActor(parent=self, thread_counter=ctr)
self.pythonActor = PythonActor(
parent=self,
script="pypushflow.test.pythonActorTest.py",
name="Python Actor Test",
thread_counter=ctr,
)
self.stopActor = StopActor(parent=self, thread_counter=ctr)
self.startActor.connect(self.pythonActor)
self.pythonActor.connect(self.stopActor)
testMyWorkflow = MyWorkflow("Test workflow 1")
inData = {"name": "Jerry"}
outData = testMyWorkflow.run(inData, timeout=15, shared_pool=True)
assert outData["reply"] == "Hello Jerry!"
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
pypushflow-0.3.0rc1.tar.gz
(18.6 kB
view details)
File details
Details for the file pypushflow-0.3.0rc1.tar.gz.
File metadata
- Download URL: pypushflow-0.3.0rc1.tar.gz
- Upload date:
- Size: 18.6 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.8.5
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
bde54b0ab9d13de74db4964adff14bf9e2bf25d8df1fae409c78410c1a4e296f
|
|
| MD5 |
13ece4fcc7fc8d5aa0c4aa79e3a1195a
|
|
| BLAKE2b-256 |
3e5a1ffc15f19cdff4d9c10a96e332c0e6ca9d0d21f36c5bb78dccc0e044fa8f
|
