Make the rejester integration work correctly, and test it.

Pass the complete streamcorpus_pipeline configuration in the rejester
work_spec 'config' field (work_spec['config']['streamcorpus_pipeline'] should
exist).  For work items pass keys as the file names to process, and
values as dictionaries { 'start_chunk_time': 0 }.

The test runs a single test locally, though it does depend on an external
redis database for synchronization.