Added scheduler and task processing thread to ec. Completed deploy and release methods.

[nepi.git] / src / neco / execution / scheduler.py

diff --git a/src/neco/execution/scheduler.py b/src/neco/execution/scheduler.py
index 202b711..2786adc 100644 (file)
--- a/src/neco/execution/scheduler.py
+++ b/src/neco/execution/scheduler.py
@@ -1,6 +1,12 @@
 import itertools
 import heapq
 
+class Task(object):
+    def __init__(self, timestamp, callback):
+        self.id = None 
+        self.timestamp = timestamp
+        self.callback = callback
+
 class HeapScheduler(object):
     """ This class is thread safe.
     All calls to C Extensions are made atomic by the GIL in the CPython implementation.