add indexing status model

Signed-off-by: Arnaud Fiorini <[email protected]>

Author: arfio

tsp/experiment.py

@@ -23,6 +23,7 @@
 """Experiment class file."""
 
 from tsp.trace_set import TraceSet
+from tsp.indexing_status import IndexingStatus
 
 NA = "N/A"
 UUID_KEY = "UUID"
@@ -86,10 +87,10 @@ def __init__(self, params):
         # Indicate if the indexing of the experiment is completed or still running.
         # If it still running, the end time and number of events are not final
         if INDEXING_STATUS_KEY in params:
-            self.indexin_status = params.get(INDEXING_STATUS_KEY)
+            self.indexing_status = IndexingStatus[params.get(INDEXING_STATUS_KEY)]
             del params[INDEXING_STATUS_KEY]
         else:  # pragma: no cover
-            self.indexin_status = 0
+            self.indexing_status = 0
 
         # Array of all the traces contained in the experiment
         if TRACES_TIME_KEY in params:

tsp/indexing_status.py

@@ -0,0 +1,20 @@
+from enum import Enum
+
+class IndexingStatus(Enum):
+    '''
+    Model is partial, data provider is still computing. If this status is
+    returned, it's viewer responsability to request again the data provider after
+    waiting some time. Request data provider until COMPLETED status is received
+    '''
+    RUNNING = "RUNNING"
+
+    '''
+    Model is complete, no need to request data provider again
+    '''
+    COMPLETED = "COMPLETED"
+
+    '''
+    
+    '''
+    CLOSED = "CLOSED"
+

tsp/trace.py

@@ -22,6 +22,9 @@
 
 """Trace class file."""
 
+from tsp.indexing_status import IndexingStatus
+
+
 NA = "N/A"
 UUID_KEY = "UUID"
 NAME_KEY = "name"
@@ -91,7 +94,7 @@ def __init__(self, params):
         # Indicate if the indexing of the trace is completed or still running.
         # If it still running, the end time and number of events are not final
         if INDEXING_STATUS_KEY in params:
-            self.indexin_status = params.get(INDEXING_STATUS_KEY)
+            self.indexing_status = IndexingStatus[params.get(INDEXING_STATUS_KEY)]
             del params[INDEXING_STATUS_KEY]
         else:  # pragma: no cover
-            self.indexin_status = 0
+            self.indexing_status = 0

tsp_cli_client

@@ -56,7 +56,7 @@ def __print_experiment(elem):
     print('----------')
     print('  {0}: ({1}) start={2} end={3} nbEvents={4} indexing={5}'.format(
         elem.name, __print_uuid(elem), elem.start, elem.end,
-        elem.number_of_events, elem.indexin_status))
+        elem.number_of_events, elem.indexing_status))
     print('Trace(s):')
     print('------')
     for elem_trace in elem.traces.traces:
@@ -68,7 +68,7 @@ def __print_experiment(elem):
 def __print_trace(elem):
     print('    {0}: {1} ({2}) start={3} end={4} nbEvents={5} indexing={6}'.format(
         elem.name, elem.path, __print_uuid(elem), elem.start, elem.end,
-        elem.number_of_events, elem.indexin_status))
+        elem.number_of_events, elem.indexing_status))
 
 
 def __print_output(output):