@@ -582,7 +582,7 @@ def getResult(self, var, meth, proc, action, action_by):
582582 values = self .memDB .getDataValuesDF ()
583583 # copy old
584584 result = self .memDB .series_service .get_series (str (values ["resultid" ][0 ]))
585- newaction = Actions ()
585+
586586
587587
588588 # change var, meth proc, in df #intend ts, agg sta
@@ -594,9 +594,7 @@ def getResult(self, var, meth, proc, action, action_by):
594594 result .ProcessingLevelID = proc .ProcessingLevelID
595595 result .ProcessingLevelObj = proc
596596
597- if meth :
598- newaction .MethodID = meth .MethodID
599- newaction .MethodObj = meth .MethodObj
597+
600598
601599 #if result does not exist
602600 if not self .memDB .series_service .resultExists (result ):
@@ -606,25 +604,36 @@ def getResult(self, var, meth, proc, action, action_by):
606604 # self.memDB.series_service.read._session.expunge(action.MethodObj.OrganizationObj)
607605 # self.memDB.series_service.read._session.expunge(action.MethodObj)
608606
607+ print "creating an action"
608+ newaction = Actions ()
609+ if meth :
610+ newaction .MethodID = meth .MethodID
611+ #newaction.MethodObj = meth.MethodOb
612+ else :
613+ newaction .MethodID = action .MethodID
609614 newaction .ActionDescription = action .ActionDescription
610615 newaction .ActionFileLink = action .ActionFileLink
611616 newaction .BeginDateTime = action .BeginDateTime
612617 newaction .BeginDateTimeUTCOffset = action .BeginDateTimeUTCOffset
613618 newaction .EndDateTime = action .EndDateTime
614619 newaction .EndDateTimeUTCOffset = action .EndDateTimeUTCOffset
615- newaction .MethodID = action .MethodID
616620 newaction .ActionTypeCV = "Derivation"
617621
618- print "creating an action"
619- newaction = self .memDB .series_service .create .createAction (newaction ) # it times out. find out why
622+ self .memDB .series_service ._session .add (newaction )
623+ self .memDB .series_service ._session .commit ()
624+ #newaction = self.memDB.series_service.create.createAction(newaction) # it times out. find out why
620625 print newaction
621626
622627
623628 # create Actionby done
624629 print "creating an actionby"
625- action_by .ActionID = newaction .ActionID
626- action_by = self .memDB .series_service .create .createActionby (action_by )
627- print action_by
630+ newaction_by = ActionBy ()
631+ newaction_by .ActionID = newaction .ActionID
632+ newaction_by .AffiliationID = action_by .AffiliationID
633+
634+ action_by = self .memDB .series_service ._session .add (newaction_by )
635+ self .memDB .series_service ._session .commit ()
636+ print newaction_by
628637
629638
630639 print "creating a feature_action"
@@ -637,7 +646,8 @@ def getResult(self, var, meth, proc, action, action_by):
637646 feature_action .ActionID = newaction .ActionID
638647 feature_action .ActionObj = newaction
639648 feature_action .SamplingFeatureObj = sampling_feature
640- feature_action = self .memDB .series_service .create .createFeatureAction (feature_action )
649+ feature_action = self .memDB .series_service ._session .add (feature_action )
650+ self .memDB .series_service ._session .commit ()
641651 print feature_action
642652
643653 print "creating a result"
@@ -656,7 +666,8 @@ def getResult(self, var, meth, proc, action, action_by):
656666 self .memDB .series_service .read ._session .expunge (result )
657667
658668
659- result = self .memDB .series_service .create .createResult (result )
669+ result = self .memDB .series_service ._session .add (result )
670+ self .memDB .series_service ._session .commit ()
660671 print result
661672 except Exception as ex :
662673 self .memDB .series_service ._session .rollback ()
0 commit comments