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.