1 |
|
from Actor import * |
2 |
|
from crab_exceptions import * |
3 |
+ |
from crab_util import * |
4 |
|
import common |
5 |
|
import string |
6 |
|
from ServerCommunicator import ServerCommunicator |
24 |
|
# get updated status from server |
25 |
|
try: |
26 |
|
stat = StatusServer(self.cfg_params) |
27 |
< |
stat.resynchClientSide() |
27 |
> |
warning_msg = stat.resynchClientSide() |
28 |
> |
if warning_msg is not None: |
29 |
> |
common.logger.info(warning_msg) |
30 |
|
except: |
31 |
|
pass |
32 |
|
|
33 |
|
# check whether the action is allowable |
34 |
< |
Cleaner.check() |
34 |
> |
self.check() |
35 |
|
|
36 |
|
# notify the server to clean the task |
37 |
|
csCommunicator = ServerCommunicator(self.server_name, self.server_port, self.cfg_params) |