from light9.collector.collector_client import sendToCollector

from twisted.internet import reactor

import traceback

import time

import logging

log = logging.getLogger()

class SubClient:

    def __init__(self):

        """assumed that your init saves self.graph"""

    def send_levels(self):

        self._send_sub()

        now = time.time()

        def done(sec):

        d = self._send_sub()

        d.addCallbacks(done, err)

        try:

            with self.graph.currentState() as g:

                outputSettings = self.get_output_settings(_graph=g)