allow sample generation if no source_url specified

(reindex on same host)

workers/sample_generator.py

@@ -30,7 +30,10 @@ def callback(channel, method, properties, body):
     #data = res.json()
 
     # get sample records from the ingest index
-    source_es = Elasticsearch([cfg['reindexer']['source_url']], timeout=60)
+    if 'source_url' in cfg['reindexer'].keys():
+        source_es = Elasticsearch([cfg['reindexer']['source_url']], timeout=60)
+    else:
+        source_es = Elasticsearch([cfg['reindexer']['destination_url']], timeout=60)
 
     the_query = dict()
     the_query['size'] = sample_size