Directed Acyclic Workflow Graph Scheduling
Project description
Directed Acyclic Workflow Graph Scheduling
import time
from dawgz import job
@job(name='A')
def a():
print('a')
time.sleep(3)
print('a')
raise Exception()
@job(name='B')
def b():
time.sleep(1)
print('b')
time.sleep(1)
print('b')
@job(name='C')
def c():
print('c')
time.sleep(1)
print('c')
c.after(a, 'any')
c.after(b)
c() # prints a b b a c c
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
dawgz-0.0.1.tar.gz
(3.3 kB
view hashes)
Built Distribution
dawgz-0.0.1-py3-none-any.whl
(3.4 kB
view hashes)