protol.py - polish

miscellaneous/agentdriver.service

@@ -5,6 +5,7 @@ BindsTo=node.service
 [Service]
 [Service]
 User=cloud
 User=cloud
 Group=cloud
 Group=cloud
+SyslogIdentifier=agentdriver
 WorkingDirectory=/home/cloud/agentdriver
 WorkingDirectory=/home/cloud/agentdriver
 ExecStart=/bin/bash -c "source /etc/profile; workon agentdriver; exec python agentdriver.py"
 ExecStart=/bin/bash -c "source /etc/profile; workon agentdriver; exec python agentdriver.py"
 Restart=always
 Restart=always

protocol.py

@@ -88,8 +88,6 @@ class SerialLineReceiver(SerialLineReceiverBase):
 
 
     def handle_command(self, command, args):
     def handle_command(self, command, args):
         logger.info('serial_command: %s %s', command, args)
         logger.info('serial_command: %s %s', command, args)
-        from kombu import Exchange, Queue
-
         if command == 'agent_stopped':
         if command == 'agent_stopped':
             logger.debug('agent_stopped %r', self.factory.vm)
             logger.debug('agent_stopped %r', self.factory.vm)
             agent_stopped.apply_async(args=(self.factory.vm, ))
             agent_stopped.apply_async(args=(self.factory.vm, ))
@@ -101,7 +99,6 @@ class SerialLineReceiver(SerialLineReceiverBase):
             )
             )
 #            logger.debug("apply_async %r", st.id)
 #            logger.debug("apply_async %r", st.id)
 #            logger.debug("apply_st6 %r", st.status)
 #            logger.debug("apply_st6 %r", st.status)
-
         elif command == 'renew':
         elif command == 'renew':
             renew.apply_async(args=(self.factory.vm, ))
             renew.apply_async(args=(self.factory.vm, ))
         elif command == 'ping':
         elif command == 'ping':