0.3.0

Full Changelog: 0.2.9...0.3.0

0.2.9

Support cron job.

Example:

import asyncio

from executor.engine import Engine
from executor.engine.job.extend.cron import CronJob, every

engine = Engine()


async def main():
    def do_something():
        print("hello")

    job = CronJob(do_something, every("1s"))
    await engine.submit_async(job)
    await engine.wait_async()


asyncio.run(main())

Full Changelog: 0.2.8...0.2.9

0.2.8

Support use async function

Full Changelog: 0.2.7...0.2.8

0.2.7

Support the send method for the generator, this feature can be used for pass data to the generator, it allow executor communicate with another thread/process:

import asyncio
from executor.engine import Engine, ProcessJob

def calculator():
    res = None
    while True:
        expr = yield res
        res = eval(expr)


async def main():
    with Engine() as engine:
        job = ProcessJob(calculator)
        await engine.submit_async(job)
        await job.wait_until_status("running")
        g = job.result()
        g.send(None)  # initialize the generator
        print(g.send("1 + 2"))  # 3
        print(g.send("3 * 4"))  # 12
        print(g.send("(1 + 2) * 4"))  # 12

asyncio.run(main())

Full Changelog: 0.2.6...0.2.7

0.2.6

What's Changed

Generator support: #3

• support sync generator by @liunux4odoo in #5
• support generator for LocalJob & ThreadJob & DaskJob by @liunux4odoo in #6

New Contributors

• @liunux4odoo made their first contribution in #5

Full Changelog: 0.2.5...0.2.6

0.2.5

Support Job.wait_until method, wait for the job to reach a certain state.

Full Changelog: 0.2.4...0.2.5

0.2.4

Full Changelog: 0.2.3...0.2.4

0.2.3

• Allow set use discache or not in the EngineSetting
• Not using the diskcache by default

Full Changelog: 0.2.2...0.2.3

0.2.2

Full Changelog: 0.2.1...0.2.2

0.2.1

Allow specify jobs in the engine.join function.