write a salt sls file in pure python.

.sls

#!py                                                                                                                                                                                         
import salt.utils                                                                                                                                                                            
import sys                                                                                                                                                                                   
                                                                                                                                                                                             
def _sub_tail(host, port, filename):                                                                                                                                                         
    import subprocess                                                                                                                                                                        
    import select                                                                                                                                                                            
    import socket                                                                                                                                                                            
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)                                                                                                                                 
    server_address = (host, port)                                                                                                                                                            
    sock.connect(server_address)                                                                                                                                                             
    p = select.poll()                                                                                                                                                                        
    fp = subprocess.Popen(['tail','-F',filename],\                                                                                                                                           
                          stdout=subprocess.PIPE,stderr=subprocess.PIPE)                                                                                                                     
    p.register(fp.stdout)                                                                                                                                                                    
    server_id = __grains__['id']                                                                                                                                                             
    sock.sendall(server_id+'\n')                                                                                                                                                             
    sock.sendall(filename+'\n')                                                                                                                                                              
                                                                                                                                                                                             
    while True:                                                                                                                                                                              
        if p.poll(1):                                                                                                                                                                        
            tmp = fp.stdout.readline()                                                                                                                                                       
            try:                                                                                                                                                                             
                sock.sendall(tmp)                                                                                                                                                            
            except:                                                                                                                                                                          
                print 'I dead'                                                                                                                                                               
                fp.kill()                                                                                                                                                                    
                sys.exit(0)                                                                                                                                                                  
                                                                                                                                                                                             
                                                                                                                                                                                             
def tail(host, port, filename):                                                                                                                                                              
    from multiprocessing import Process                                                                                                                                                      
    p = Process(target=_sub_tail, args=(host, port, filename))                                                                                                                               
    p.start()                                                                                                                                                                                
    return {'retcode': 0, 'stdout': 'ok', 'stderr': ''}                                                                                                                                      
                                                                                                                                                                                             
def run():                                                                                                                                                                                   
    host = __pillar__['tail']['host']                                                                                                                                                        
    port = __pillar__['tail']['port']                                                                                                                                                        
    filename = __pillar__['tail']['filename']                                                                                                                                                
    ret = tail(host, port, filename)                                                                                                                                                         
    return ret