old_contents: import hive
  import threading
  import time
  import sys
  import worker
  
  # import pash from another directory
  import pash
  
  class ErrWorker(worker.Worker):
  	def work(self, command):
  		proc = pash.ShellProc()
  		proc.run(command)
  		return "Exit code: %s" % proc.get_val('exit_code')
  def test():
  	apiary = hive.Hive()
  	apiary.create_queen('A1')
  
  	apiary.create_queen('A2')
  
  	apiary.start_queen('A1')
  
  	apiary.start_queen('A2')
  
  	data = ["iscsiadm -m discovery -t st -p 192.168.88.110 -I default","iscsiadm -m discovery -t st -p 192.168.90.110 -I iface1","iscsiadm -m discovery -t st -p 192.168.88.110 -I iface0"]
  	apiary.instruct_queen('A1',data, ErrWorker)
  
  	apiary.kill_queen('A1')
  
  	time.sleep(3)
  
  	this = apiary.die()
  
  	for key in this.keys():
  		for i in this[key]:
  			print i
  
  	sys.exit(0)
  
new_contents: import threading
  import time
  import sys
  
  from busybees import worker
  from busybees import hive
  
  import pash
  
  class ErrWorker(worker.Worker):
  	def work(self, command):
  		proc = pash.ShellProc()
  		proc.run(command)
  		return "Exit code: %s" % proc.get_val('exit_code')
  
  def test():
  	apiary = hive.Hive()
  	apiary.create_queen('A1')
  
  	apiary.create_queen('A2')
  
  	apiary.start_queen('A1')
  
  	apiary.start_queen('A2')
  
  	data = ["iscsiadm -m discovery -t st -p 192.168.88.110 -I default","iscsiadm -m discovery -t st -p 192.168.90.110 -I iface1","iscsiadm -m discovery -t st -p 192.168.88.110 -I iface0"]
  	apiary.instruct_queen('A1',data, ErrWorker)
  
  	apiary.kill_queen('A1')
  
  	time.sleep(3)
  
  	this = apiary.die()
  
  	for key in this.keys():
  		for i in this[key]:
  			print i
  
  	sys.exit(0)
  
subject: Change imports to work with new scheme