← Back to branch summary

~christopher-hunt08/maus/maus_integrated_kalman

« back to all changes in this revision

Viewing changes to src/common_py/framework/input_transform.py

  • Committer: Durga Rajaram
  • Date: 2014-07-16 15:13:05 UTC
  • mfrom: (659.1.92 cand)
  • Revision ID: durga@fnal.gov-20140716151305-q27rv1y9p03v9lks
Tags: MAUS-v0.9, MAUS-v0.9.0
MAUS-v0.9.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/common_py/framework/input_transform.py
25
25
import celery.states
26
26
import celery.task.control
27
27
 
 
28
import maus_cpp.converter
 
29
 
28
30
from docstore.DocumentStore import DocumentStoreException
29
31
from framework.utilities import CeleryUtilities
30
32
from framework.utilities import DataflowUtilities
267
269
 
268
270
        # reset input
269
271
        print("INPUT: Birth")
270
 
        if (not self.inputer.birth(self.config_doc)):
 
272
        if self.inputer.birth(self.config_doc) == False:
271
273
            raise WorkerBirthFailedException(self.inputer.__class__)
272
274
        emitter = self.inputer.emitter()
273
275
        map_buffer = DataflowUtilities.buffer_input(emitter, 1)
305
307
        Process a single event - if it is a Spill, check for run_number change
306
308
        and call EndOfEvent/StartOfEvent if run_number has changed.
307
309
        """
308
 
        event_json = json.loads(event)
 
310
        event_json = maus_cpp.converter.json_repr(event)
309
311
        if DataflowUtilities.get_event_type(event_json) == "Spill":
310
312
            current_run_number = DataflowUtilities.get_run_number(event_json)
311
313
            if current_run_number != self.run_number:
314
316
                self.start_of_run(current_run_number)
315
317
                self.run_number = current_run_number
316
318
            self.spill_input_count += 1
317
 
            self.submit_spill_to_celery(event)
 
319
            event_str = maus_cpp.converter.string_repr(event_json)
 
320
            self.submit_spill_to_celery(event_str)
318
321
 
319
322
    @staticmethod
320
323
    def get_dataflow_description():