mirror of
https://github.com/Pardus-LiderAhenk/ahenk
synced 2024-11-10 15:52:22 +03:00
execution manager implementing
This commit is contained in:
parent
b6b5e53740
commit
eb4ee5009b
1 changed files with 3 additions and 5 deletions
|
@ -2,7 +2,7 @@
|
||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
# Author: Volkan Şahin <volkansah.in> <bm.volkansahin@gmail.com>
|
# Author: Volkan Şahin <volkansah.in> <bm.volkansahin@gmail.com>
|
||||||
import sys
|
import sys
|
||||||
import logging
|
import logging,subprocess
|
||||||
import logging.config
|
import logging.config
|
||||||
from base.Scope import Scope
|
from base.Scope import Scope
|
||||||
|
|
||||||
|
@ -27,11 +27,9 @@ class ExecutionManager(object):
|
||||||
print("execute_script")
|
print("execute_script")
|
||||||
j = json.loads(arg)
|
j = json.loads(arg)
|
||||||
msg_id =str(j['id']).lower()
|
msg_id =str(j['id']).lower()
|
||||||
file_path =str(j['filePath']).lower()
|
file_name =str(j['filePath']).lower()
|
||||||
time_stamp=str(j['timestamp']).lower()
|
time_stamp=str(j['timestamp']).lower()
|
||||||
|
subprocess.call("/bin/sh "+self.conf_manager.get('CONNECTION', 'receivefileparam')+file_name, shell=True)
|
||||||
os.system('./command.sh') #TODO
|
|
||||||
|
|
||||||
|
|
||||||
#need to move somewhere else
|
#need to move somewhere else
|
||||||
def send_file(self,arg):
|
def send_file(self,arg):
|
||||||
|
|
Loading…
Reference in a new issue