def setup_queue(options):	
	probe_servers = Queue()
	progress_queue = Queue()
	
	source_name=options.source_name.strip('"').strip()
	
	sort_order = None
	sort_order_def = Probe.ProbeRunSort.objects.get_or_create(sort_name="__default__", defaults={"sort_rank":1000})[0]
	sort_order_q = Probe.ProbeRunSort.objects.filter(sort_name=source_name)
	if sort_order_q.count() > 0:
		sort_order = sort_order_q[0]
	else:
		sort_order = sort_order_def
	

	run = Probe.ProbeRun.objects.create(
									source_name=source_name, 
									description=options.description.strip('"').strip(),
									branch = options.branch.strip('"').strip() if options.branch and options.branch.strip('"').strip() else None,
									sort_rank = sort_order
									)

	summary_top = Results.ResultSummaryList(part_of_run=run)
	summary_top.save()
	summary_top.setup()

	cluster_task = Cluster.ClusterRun.objects.create(perform_run = run, enabled=True, priority=options.priority)
	
	if options.input_queue or options.input_queue_id:
		if options.input_queue_id:
			queue_list = Probe.PreparedQueueList.objects.get(id=options.input_queue_id)
		else:
			queue_list = Probe.PreparedQueueList.objects.get(list_name=options.input_queue)
			
		queue_list.InitQueue(run)
		
		cluster_task.enabled=True
		cluster_task.save()
		return run

	connection.close()
	
	threads = [] 
	for i in range(options.threads):
		new_thread = Process(target=SetupQueueThread, args=(i,run, probe_servers, progress_queue))
		new_thread.daemon = True
		new_thread.start()
		threads.append(new_thread)
		
	progress_thread = threading.Thread(target=__ProgressCounter, args=(run, cluster_task, progress_queue, threads,options))
	progress_thread.daemon = True
	progress_thread.start()

	i = 0;
	if not options.file_list_only:
		for host in Probe.Server.objects.filter(enabled = True).values_list("id",flat=True):
			probe_servers.put(host)
			i+=1
			if options.count and i is not options.count:
				break;

	if options.input_filename and (not options.count or i < options.count):
		for hostname_line in fileinput.input(options.input_filename, openhook=fileinput.hook_compressed):
			probe_servers.put(hostname_line)
			i+=1
			if options.count and i >= options.count:
				break;

	probe_servers.join()
	progress_queue.join()
	
	for i in range(0,3):
		connection.cursor().execute("ANALYZE "+ ("VERBOSE " if options.verbose else "")+"probedata2_probequeue")
	
	cluster_task.enabled=True
	cluster_task.save()
	
	return run
dataset/ETHPy150Open operasoftware/tlsprober/cluster_setup.py/setup_queue/operator `>=` -> `is not`