Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Creating a stream on each shard
'XADD', 'edges_matched_{%s}' % shard_id, '*','source',f'{source_entity_id}','destination',f'{destination_entity_id}','source_name',source_canonical_name,'destination_name',destination_canonical_name,'rank',1,'year',year)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment