meshulam

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):

meshulam

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"""