Skip to content

Instantly share code, notes, and snippets.

Avatar

Lewis Franklin brolewis

  • Erie, CO
View GitHub Profile
@brolewis
brolewis / schedulers.py
Last active Jun 28, 2020
A distributed job scheduler for Celery using ZooKeeper (via kazoo) to manage the locking.
View schedulers.py
'''Zookeeper-based Scheduler'''
## Standard Library
import cPickle # Store dictionary in ZooKeeper
import datetime # Time delta
import socket # Hostname
## Third Party
import celery # Current app
import celery.beat # Scheduler
import celery.utils.log # Get logger
import kazoo.client # ZooKeeper Client Library
You can’t perform that action at this time.