|
|
|
@ -26,7 +26,7 @@ from os import path
|
|
|
|
|
import glob
|
|
|
|
|
import traceback
|
|
|
|
|
from traceback import print_exc
|
|
|
|
|
from calculate.core.server.core_interfaces import (CoreServiceInterface,
|
|
|
|
|
from .core_interfaces import (CoreServiceInterface,
|
|
|
|
|
MethodsInterface)
|
|
|
|
|
from calculate.install.distr import Distributive
|
|
|
|
|
from calculate.lib.cl_log import log
|
|
|
|
@ -48,9 +48,8 @@ from itertools import *
|
|
|
|
|
import calculate.contrib
|
|
|
|
|
from spyne import String, Integer, Boolean, Array
|
|
|
|
|
|
|
|
|
|
from calculate.core.server.api_types import ReturnedMessage, CommonInfo
|
|
|
|
|
from calculate.core.server.api_types import (Field,
|
|
|
|
|
GroupField, ViewInfo, ViewParams)
|
|
|
|
|
from .api_types import ReturnedMessage, CommonInfo
|
|
|
|
|
from .api_types import (Field, GroupField, ViewInfo, ViewParams)
|
|
|
|
|
from calculate.lib.cl_template import Template
|
|
|
|
|
from calculate.lib.datavars import DataVars
|
|
|
|
|
from .loaded_methods import LoadedMethods
|
|
|
|
@ -836,7 +835,7 @@ def catchExcept(*skipException):
|
|
|
|
|
try:
|
|
|
|
|
return self.f(*args, **kwargs)
|
|
|
|
|
except BaseException as e:
|
|
|
|
|
from calculate.core.server.api_types import ViewInfo, \
|
|
|
|
|
from .api_types import ViewInfo, \
|
|
|
|
|
GroupField, Field
|
|
|
|
|
|
|
|
|
|
if isinstance(e, KeyboardInterrupt):
|
|
|
|
@ -1049,13 +1048,13 @@ class CoreWsdl(CoreServiceInterface):
|
|
|
|
|
self.Num = 100000
|
|
|
|
|
|
|
|
|
|
def pauseProcess(self):
|
|
|
|
|
from calculate.core.server.gen_pid import ProcessStatus
|
|
|
|
|
from .gen_pid import ProcessStatus
|
|
|
|
|
|
|
|
|
|
self.method_status = ProcessStatus.Paused
|
|
|
|
|
self.writeFile()
|
|
|
|
|
|
|
|
|
|
def resumeProcess(self):
|
|
|
|
|
from calculate.core.server.gen_pid import ProcessStatus
|
|
|
|
|
from .gen_pid import ProcessStatus
|
|
|
|
|
|
|
|
|
|
self.method_status = ProcessStatus.Worked
|
|
|
|
|
self.writeFile()
|
|
|
|
@ -1063,7 +1062,7 @@ class CoreWsdl(CoreServiceInterface):
|
|
|
|
|
def writeFile(self):
|
|
|
|
|
""" write data in file """
|
|
|
|
|
from .baseClass import Basic
|
|
|
|
|
from calculate.core.server.gen_pid import ProcessMode
|
|
|
|
|
from .gen_pid import ProcessMode
|
|
|
|
|
|
|
|
|
|
if not os.path.exists(Basic.pids):
|
|
|
|
|
makeDirectory(Basic.pids)
|
|
|
|
|