def __ProgressCounter(run, cluster_task, queue, threads, options):
	i=0
	while True:
		queue.get()

		i += 1
		if i%100 == 0:
			if options.verbose:
				print "Queued ", i, "servers so far. Threads active ", sum([t.is_alive() for t in threads])

		if i>3000000 or not cluster_task.enabled:				
			cluster_task.enabled=True
			cluster_task.save

		queue.task_done()
dataset/ETHPy150Open operasoftware/tlsprober/cluster_setup.py/__ProgressCounter/operator `and` -> `or`