shaclapi.multiprocessing.contactSource module#
- shaclapi.multiprocessing.contactSource.contactSource(queue, endpoint, query, limit=-1)[source]#
Normal contactSource implementation but queue is filled with an output, which is in a format which is joinable with validation results. Queue_copy contains the normal result but with an ID.
Example
- Input:
{var1: instance1, var2: instance2, var3: instance3}
- Output queue:
{‘instance’: instance1, ‘var’: var1, ‘id’: UNIQUE_RESULT_ID}, {‘instance’: instance2, ‘var’: var2, ‘id’: UNIQUE_RESULT_ID}, {‘instance’: instance3, ‘var’: var3, ‘id’: UNIQUE_RESULT_ID}
- Output queue_copy:
{‘query_result’: {‘var1’: instance1, ‘var2’: instance2, ‘var3’: instance3}, ‘id’: UNIQUE_RESULT_ID}