import time
from openerp import SUPERUSER_ID
-from openerp import netsvc, tools
+from openerp import tools
from openerp.osv import fields, osv
import openerp.report.interface
from openerp.report.report_sxw import report_sxw, report_rml
from openerp.tools.config import config
from openerp.tools.safe_eval import safe_eval as eval
from openerp.tools.translate import _
+import openerp.workflow
_logger = logging.getLogger(__name__)
_logger.warning('Failed to send email to: %s', addresses)
if action.state == 'trigger':
- wf_service = netsvc.LocalService("workflow")
model = action.wkf_model_id.model
m2o_field_name = action.trigger_obj_id.name
target_id = obj_pool.read(cr, uid, context.get('active_id'), [m2o_field_name])[m2o_field_name]
target_id = target_id[0] if isinstance(target_id,tuple) else target_id
- wf_service.trg_validate(uid, model, int(target_id), action.trigger_name, cr)
+ openerp.workflow.trg_validate(uid, model, int(target_id), action.trigger_name, cr)
if action.state == 'sms':
#TODO: set the user and password from the system
import openerp
from openerp import SUPERUSER_ID
-from openerp import netsvc, pooler, tools
+from openerp import pooler, tools
from openerp.osv import fields,osv
from openerp.osv.orm import Model
from openerp.tools.safe_eval import safe_eval as eval
wkf_todo.extend(cr.fetchall())
cr.execute("update wkf_transition set condition='True', group_id=NULL, signal=NULL,act_to=act_from,act_from=%s where act_to=%s", (res_id,res_id))
- wf_service = netsvc.LocalService("workflow")
for model,res_id in wkf_todo:
try:
- wf_service.trg_write(uid, model, res_id, cr)
+ openerp.workflow.trg_write(uid, model, res_id, cr)
except Exception:
_logger.info('Unable to force processing of workflow for item %s@%s in order to leave activity to be deleted', res_id, model, exc_info=True)
from openerp.osv import fields, osv
from openerp.tools.translate import _
-from openerp import netsvc
+import openerp.workflow
class workflow(osv.osv):
_name = "workflow"
def write(self, cr, user, ids, vals, context=None):
if not context:
context={}
- wf_service = netsvc.LocalService("workflow")
- wf_service.clear_cache(cr, user)
+ openerp.workflow.clear_cache(cr, user)
return super(workflow, self).write(cr, user, ids, vals, context=context)
def get_active_workitems(self, cr, uid, res, res_id, context=None):
def create(self, cr, user, vals, context=None):
if not context:
context={}
- wf_service = netsvc.LocalService("workflow")
- wf_service.clear_cache(cr, user)
+ openerp.workflow.clear_cache(cr, user)
return super(workflow, self).create(cr, user, vals, context=context)
workflow()
import openerp.pooler as pooler
from openerp.tools.translate import _
-import openerp.netsvc as netsvc
-
import zipfile
import openerp.release as release
import openerp.pooler as pooler
from openerp.tools.translate import _
-import openerp.netsvc as netsvc
-
import zipfile
import openerp.release as release
# for eval context:
import time
-import openerp.release as release
+
+import openerp.release
+import openerp.workflow
import assertion_report
time=time,
DateTime=datetime,
timedelta=timedelta,
- version=release.major_version,
+ version=openerp.release.major_version,
ref=_ref(self, cr),
pytz=pytz)
if len(model_str):
id = _eval_xml(self, rec[0], self.pool, cr, self.uid, self.idref)
uid = self.get_uid(cr, self.uid, data_node, rec)
- import openerp.netsvc as netsvc
- wf_service = netsvc.LocalService("workflow")
- wf_service.trg_validate(uid, model,
+ openerp.workflow.trg_validate(uid, model,
id,
str(rec.get('action','')), cr)
import openerp.pooler as pooler
import openerp.sql_db as sql_db
+import openerp.workflow
import misc
from config import config
import yaml_tag
signals=[x['signal'] for x in self.cr.dictfetchall()]
if workflow.action not in signals:
raise YamlImportException('Incorrect action %s. No such action defined' % workflow.action)
- import openerp.netsvc as netsvc
- wf_service = netsvc.LocalService("workflow")
- wf_service.trg_validate(uid, workflow.model, id, workflow.action, self.cr)
+ openerp.workflow.trg_validate(uid, workflow.model, id, workflow.action, self.cr)
def _eval_params(self, model, params):
args = []