<commit_before>package net.greghaines.jesque;

import static net.greghaines.jesque.TestUtils.createJedis;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import net.greghaines.jesque.worker.Worker;
import net.greghaines.jesque.worker.WorkerImpl;

import org.junit.Before;
import org.junit.Test;

import redis.clients.jedis.Jedis;

public class InfiniteTest
{
	private static final Config config = new ConfigBuilder().withJobPackage("net.greghaines.jesque").build();
	
	@Before
	public void resetRedis()
	throws Exception
	{
		final Jedis jedis = createJedis(config);
		try
		{
			jedis.flushDB();
		}
		finally
		{
			jedis.quit();
		}
	}
	
	@Test
	public void dummy(){}
	
	@SuppressWarnings("unchecked")
//	@Test
	public void dontStopNow()
	throws InterruptedException
	{
		for (int i = 0; i < 5; i++)
		{
			final List<Job> jobs = new ArrayList<Job>(30);
			for (int j = 0; j < 30; j++)
			{
				jobs.add(new Job("TestAction", new Object[]{j, 2.3, true, "test", Arrays.asList("inner", 4.5)}));
			}
			TestUtils.enqueueJobs("foo" + i, jobs, config);
			jobs.clear();
			for (int j = 0; j < 5; j++)
			{
				jobs.add(new Job("FailAction"));
			}
			TestUtils.enqueueJobs("bar", jobs, config);
		}
		final Worker worker = new WorkerImpl(config, Arrays.asList("bar","baz"), Arrays.asList(TestAction.class, FailAction.class));
		final Thread workerThread = new Thread(worker);
		workerThread.start();
		
		TestUtils.enqueueJobs("inf", Arrays.asList(new Job("InfiniteAction")), config);<commit_msg>Minor change to InfiniteTest.<commit_after>package net.greghaines.jesque;

import static net.greghaines.jesque.TestUtils.createJedis;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import net.greghaines.jesque.worker.Worker;
import net.greghaines.jesque.worker.WorkerImpl;

import org.junit.Before;
import org.junit.Test;

import redis.clients.jedis.Jedis;

public class InfiniteTest
{
	private static final Config config = new ConfigBuilder().withJobPackage("net.greghaines.jesque").build();
	
	@Before
	public void resetRedis()
	throws Exception
	{
		final Jedis jedis = createJedis(config);
		try
		{
			jedis.flushDB();
		}
		finally
		{
			jedis.quit();
		}
	}
	
	@Test
	public void dummy(){}
	
	@SuppressWarnings("unchecked")
//	@Test
	public void dontStopNow()
	throws InterruptedException
	{
		for (int i = 0; i < 5; i++)
		{
			final List<Job> jobs = new ArrayList<Job>(30);
			for (int j = 0; j < 30; j++)
			{
				jobs.add(new Job("TestAction", new Object[]{j, 2.3, true, "test", Arrays.asList("inner", 4.5)}));
			}
			TestUtils.enqueueJobs("foo" + i, jobs, config);
			jobs.clear();
			for (int j = 0; j < 5; j++)
			{
				jobs.add(new Job("FailAction"));
			}
			TestUtils.enqueueJobs("bar", jobs, config);
		}
		final Worker worker = new WorkerImpl(config, Arrays.asList("foo0", "bar","baz"), Arrays.asList(TestAction.class, FailAction.class));
		final Thread workerThread = new Thread(worker);
		workerThread.start();
		
		TestUtils.enqueueJobs("inf", Arrays.asList(new Job("InfiniteAction")), config);
{'fraction_non_alphanumeric': 0.15029277813923228, 'fraction_numerical': 0.00878334417696812, 'mean_word_length': 4.1767676767676765, 'pattern_counts': {'":': 0, '<': 13, '<?xml version=': 0, '>': 7, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2976516', 'n_tokens_mistral': 1219, 'n_tokens_neox': 1096, 'n_words': 241}