[feat]is there a plan to support generator?

[liunux4odoo]

• Executor version: 0.2.5
• Python version: 3.10
• Operating System: win10

Description

Running generator as job raises pickle error.

What I Did

from executor.engine import Engine, ProcessJob


def f():
    import time
    for i in range(3):
        time.sleep(1)
        yield i


with Engine() as engine:
    job = ProcessJob(f)
    engine.submit(job)
    engine.wait()
    print(job.result())

[Nanguage]

This feature is not supported at the moment, but I will think about how to support it.

[Nanguage]

The new release 0.2.6 has supported this feature, it has been uploaded to the PyPI.

[Nanguage]

The send method for the generator is supported in the new release 0.2.7, 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())

see 669d71f