import asyncio
import multiprocessing
import motor.motor_asyncio

class Blah:
    @staticmethod
    async def publish():
        connection = motor.motor_asyncio.AsyncIOMotorClient(host='localhost')['SNP']
        res = await connection.publish_logs.find_one()
        return res.get('_id')


def worker_main():
    return asyncio.run(do_work())

async def do_work():
    blah = await Blah.publish()
    return blah


def run_tasks(tasks=None):
    workers = len(tasks)
    results = []
    with multiprocessing.Pool(processes=workers) as pool:
        for task in tasks:
            async_result = pool.apply_async(worker_main)
            results.append(async_result)

        pool.close()
        pool.join()

        # Print task results
        for result in results:
            print(result.get())


async def build_tasks():
    # if I comment these three lines it "works" on the multiprocess tasks
    connection = motor.motor_asyncio.AsyncIOMotorClient(host='localhost')['SNP']
    res = await connection.publish_logs.find_one()
    print(res.get('_id'))

    chunks = []
    for c in range(8):
        blah = []
        chunks.append(blah)

    return chunks


if __name__ == '__main__':

    t = asyncio.run(build_tasks())
    run_tasks(t)