Skip to content

Commit d477a7e

Browse files
committed
Don't use mapping types
1 parent 181cf69 commit d477a7e

1 file changed

Lines changed: 8 additions & 6 deletions

File tree

datapackage_pipelines_migdar/flows/dump_to_es.py

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -185,14 +185,16 @@ def es_dumper(resource_name, revision, path):
185185
return DF.Flow(
186186
update_pk('doc_id'),
187187
DF.add_field('revision', 'integer', default=revision),
188-
DumpToElasticSearch({'migdar': [{'resource-name': resource_name,
189-
'doc-type': resource_name,
190-
'revision': revision}]})(),
188+
DumpToElasticSearch({'migdar__' + resource_name:
189+
[{'resource-name': resource_name,
190+
'doc-type': None,
191+
'revision': revision}]})(),
191192
DF.dump_to_path('data/{}'.format(path)),
192193
collate(revision),
193-
DumpToElasticSearch({'migdar': [{'resource-name': resource_name,
194-
'doc-type': 'document',
195-
'revision': revision}]})(),
194+
DumpToElasticSearch({'migdar__docs':
195+
[{'resource-name': resource_name,
196+
'doc-type': None,
197+
'revision': revision}]})(),
196198
DF.update_resource(None, **{'dpp:streaming': True}),
197199
DF.printer(),
198200
)

0 commit comments

Comments
 (0)