aboutsummaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools/workers/worker_common.py
Commit message (Collapse)AuthorAgeFilesLines
* typing: add annotations to remaining fatcat_tools codeBryan Newbold2021-11-031-3/+12
| | | | | Again, these are just annotations, no changes made to get type checks to pass
* fmt (black): fatcat_tools/Bryan Newbold2021-11-021-17/+15
|
* lint (flake8) tool python filesBryan Newbold2020-07-011-9/+0
|
* small fixes to confluent-kafka importers/workersBryan Newbold2019-09-201-5/+1
| | | | | | | | - decrease default changelog pipeline to 5.0sec - fix missing KafkaException harvester imports - more confluent-kafka tweaks - updates to kafka consumer configs - bump elastic updates consumergroup (again)
* convert pipeline workers from pykafka to confluent-kafkaBryan Newbold2019-09-201-29/+48
|
* refactor all python source for client lib nameBryan Newbold2019-09-051-2/+2
|
* 10 MByte default Kafka produce (workers)Bryan Newbold2019-03-061-0/+3
|
* bunch of lint/whitespace cleanupsBryan Newbold2019-02-221-2/+2
|
* workers do API-passing (not URI-passing)Bryan Newbold2019-01-081-5/+3
|
* have recent message helper cleanup consumerBryan Newbold2018-11-151-1/+5
|
* fix worker codeBryan Newbold2018-11-141-0/+2
|
* most_recent_message as reusable functionBryan Newbold2018-11-141-0/+25
|
* shuffle around fatcat_tools layoutBryan Newbold2018-11-131-0/+25