Skip to content

Instantly share code, notes, and snippets.

View meshulam's full-sized avatar

Matt Meshulam meshulam

  • University of Minnesota
  • Minneapolis, MN
View GitHub Profile
import dateutil.parser
import optparse
from Queue import Queue
from tempodb.client import Client
from tempodb.protocol import DataPoint
from threading import Thread
class Worker(Thread):
"""Thread executing tasks from a given tasks queue"""
import datetime
import dateutil.parser
import optparse
from Queue import Queue
import tempodb
from threading import Thread
class Worker(Thread):
"""Thread executing tasks from a given tasks queue"""
def __init__(self, tasks):