AndreiPashkin

from sqlalchemy import Column, Integer, String, ForeignKey, create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import relationship, backref, sessionmaker, joinedload

# For this example we will use an in-memory sqlite DB.
# Let's also configure it to echo everything it does to the screen.
engine = create_engine('sqlite:///:memory:', echo=True)

# The base class which our objects will be defined on.
Base = declarative_base()

AndreiPashkin

import time
import multiprocessing as mp
import queue as queuelib


N_PROCESSES = 4


def worker(queue: mp.Queue, stop: mp.Event):
    print(f"Start job: {mp.current_process().name}")