def SetupQueueThread(tid, run, probe_servers, progress_queue, ):
	connection.close()
	try:
		while True:
			item = probe_servers.get()

			if isinstance(item, int):
				try:
					item = Probe.Server.objects.get(id=item)
				except:
					probe_servers.task_done()
					continue
					
				hostname = item.servername.strip()
				if (not hostname or 
						any([x in hostname for x in " \t%/&#\"'\\{[]}()*,;<>$"]) or 
						any([ord(x)>=128 or ord(x)<=32  for x in hostname])):
					item.enabled = False
					item.save()
					probe_servers.task_done()
					continue

				hostname = hostname.strip(".")
				while hostname.find("..")>=0:
					hostname = hostname.replace("..", ".")
				
				if hostname != item.servername:
					item.enabled = False
					item.save()
					item = "0," + hostname+","+str(item.port)+","+item.protocol # Convert to string to correct the list 

			if not isinstance(item, Probe.Server):
				hostname_line = item
				
				if not hostname_line.strip():
					probe_servers.task_done()
					continue
			
				split_line = hostname_line.strip().split(",")
			
				if len(split_line) > 3:
					(index, hostname, port, protocol) = split_line[:4]
					port = port.strip()
					protocol = protocol.strip()
					if not protocol or protocol.upper() not in Probe.Server.PROTOCOL_PORT_MAP:
						protocol = Probe.Server.PROTOCOL_PORT.get(int(port) if port else 443, Probe.Server.PROTOCOL_HTTPS) 
				elif len(split_line) > 2:
					(index, hostname, port) = split_line[:3]
					port = port.strip()

					protocol = Probe.Server.PROTOCOL_PORT.get(int(port) if port else 443, Probe.Server.PROTOCOL_HTTPS) 
				else: 
					port = ""
					(var1, var2) = split_line
					if var1.isdigit():
						(index, hostname) = (var1, var2)
					else:
						(hostname, port) =  (var1, var2)
						port=port.strip()
					protocol = Probe.Server.PROTOCOL_PORT.get(int(port) if port else 443, Probe.Server.PROTOCOL_HTTPS) 
						
				
				hostname = hostname.strip()
				if (not hostname or 
						any([x in hostname for x in " \t%/&#\"'\\{[]}()*,;<>$"]) or 
						any([ord(x)>=128 or ord(x)<=32  for x in hostname])):
					probe_servers.task_done()
					continue
				
				hostname = hostname.strip(".")
				while hostname.find("..") is 0:
					hostname = hostname.replace("..", ".")
					
				if not port:
					port = 443
				else:
					port = int(port)
	
				sn_t = "%s:%05d:%s" % (hostname, port,protocol)
				(item, created) = Probe.Server.objects.get_or_create(
									full_servername = sn_t,
									defaults={'enabled':True,
											"alexa_rating":0,
											"servername":hostname, 
											"port": port, 
											"protocol":protocol.upper(), 
											}
									)

				if created:
					item.Construct()

			if item.enabled:
				try:	
					#run_entry = Probe.ProbeQueue.objects.create(part_of_run=run,server=item,state=Probe.ProbeQueue.PROBEQ_IDLE)
					sid = transaction.savepoint()
					cursor = connection.cursor()
					cursor.execute("""INSERT INTO probedata2_probequeue (part_of_run_id, server_id, state)  
							VALUES (%s,%s,%s)""", [str(run.id), str(item.id), Probe.ProbeQueue.PROBEQ_IDLE]
						)
					transaction.savepoint_commit(sid)
					transaction.commit_unless_managed()
					progress_queue.put(True)
				except:
					transaction.savepoint_rollback(sid)
					pass

			probe_servers.task_done()
	except:
		pass
dataset/ETHPy150Open operasoftware/tlsprober/cluster_setup.py/SetupQueueThread/operator `>=` -> `is`