# HG changeset patch # User drewp@bigasterisk.com # Date 1559965909 0 # Node ID fc66b28302a50ac88193f288e2faacb9fa03af0c # Parent 6e1b06199cff4d6794c61f9be7950df4ba1a4804 some types for subclient Ignore-this: a01ce3ca8427241d5f543e427167891d diff -r 6e1b06199cff -r fc66b28302a5 light9/subclient.py --- a/light9/subclient.py Sat Jun 08 03:50:57 2019 +0000 +++ b/light9/subclient.py Sat Jun 08 03:51:49 2019 +0000 @@ -1,13 +1,18 @@ from light9.collector.collector_client import sendToCollector from twisted.internet import reactor +from twisted.internet.defer import Deferred import traceback import time import logging +from rdflib import URIRef +from rdfdb.syncedgraph import SyncedGraph log = logging.getLogger() class SubClient: - + graph: SyncedGraph + session: URIRef + def __init__(self): """assumed that your init saves self.graph""" pass # we may later need init code for network setup @@ -19,7 +24,7 @@ def send_levels(self): self._send_sub() - def send_levels_loop(self, delay=1000): + def send_levels_loop(self, delay=1000) -> None: now = time.time() def done(sec): @@ -34,7 +39,7 @@ d = self._send_sub() d.addCallbacks(done, err) - def _send_sub(self): + def _send_sub(self) -> Deferred: try: with self.graph.currentState() as g: outputSettings = self.get_output_settings(_graph=g)