Installation $ [sudo] pip install pg-task-queue Add task example from pg_tasks_queue.TaskManager import TaskManager task_manager = TaskManager() database_dict = {'host': '127.0.0.1', 'port': '5432', 'dbname': 'task_queue', 'schema': 'public', 'user': '<user_login>', 'password': '<user_password>'} if task_manager.init(database_dict): task_dict = {'module': '<module_name>', 'func': '<function_name>', 'priority': 1, 'params': {'counter': 3}, 'max_retry_count': 3} task_id = task_manager.add_task(task_dict) Start worker example from pg_tasks_queue.Worker import Worker worker = Worker() config_dict = { 'database': {'host': '127.0.0.1', 'port': '5432', 'dbname': 'task_queue', 'schema': 'public', 'user': '<user_login>', 'password': '<user_password>'}, 'worker': {'timeout_sec': 30., 'sleep_sec': .5} } if worker.init(config_dict): worker.start()