valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-08 09:23:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add a log message when jobs are published

Browse Source
This commit is contained in:
Thomas S Hatch 2012-01-31 14:34:40 -07:00
parent 9d55628dad
commit 821b8e3629
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
salt/client.py
View File

@ -369,6 +369,8 @@ class LocalClient(object):
self.opts
)
)
log.info(('Publishing job: #{0[jid]}, func: "{0[fun]}", args:'
' "{0[args]}", target: "{0[tgt]}"').format(load))
socket.send(package)
payload = None
for ind in range(100):

3
salt/master.py
View File

@ -171,7 +171,6 @@ class Publisher(multiprocessing.Process):
try:
while True:
package = pull_sock.recv()
log.info('Publishing command')
pub_sock.send(package)
except KeyboardInterrupt:
pub_sock.close()
@ -606,6 +605,8 @@ class AESFuncs(object):
os.path.join(self.opts['sock_dir'], 'publish_pull.ipc')
)
pub_sock.connect(pull_uri)
log.info(('Publishing minion job: #{0[jid]}, func: "{0[fun]}", args:'
' "{0[args]}", target: "{0[tgt]}"').format(load))
pub_sock.send(self.serial.dumps(payload))
# Run the client get_returns method
return self.local.get_returns(