Pysqa integration

[jan-janssen]

No description provided.

[jan-janssen]

Current test script:

import numpy as np
from pympipool import Pool
from pysqa import QueueAdapter


def calc(i):
    return np.array(i ** 2)


if __name__ == "__main__":
    qa = QueueAdapter(directory="/home/user/.queues")
    with Pool(
        max_workers=2,
        cwd="/home/user/test",
        queue_adapter=qa, 
        queue_adapter_kwargs={
            "job_name": "pympipool", 
        }
    ) as p:
        print(p.map(func=calc, iterable=[1, 2, 3, 4]))