Hastebin

import redis
import multiprocessing
from celery import Celery, current_task

app = Celery("cel_main",
             broker_url="pyamqp://guest@localhost//",
             backend="redis://localhost:6379/0")



r = redis.StrictRedis(host="localhost", port=6379)



lock = multiprocessing.Lock()

manager = multiprocessing.Manager()
l = manager.list()


@app.task
def add_to_list():

    # print(f"task {current_task.request.id} waiting for lock")
    # with lock:
    #     print(f"task {current_task.request.id} acquired lock")
    #     l.append(current_task.request.id)
    #
    # print(f"task {current_task.request.id} released")

    l.append(current_task.request.id)