Make it public #4
Conversation
|
@pachCode @rogelioLpz actualmente esta fallando Travis porque el proyecto no es OpenSource, en cuanto le den aprobar, lo haré público y todo debería funcionar |
| try: | ||
| kinesis_client.create_stream(StreamName=stream_name, ShardCount=1) | ||
| except kinesis_client.exceptions.ResourceInUseException: | ||
| time.sleep(1) |
There was a problem hiding this comment.
Cuando haces muchas peticiones seguidas, AWS te manda esa excepción.
hub/workers/worker.py
Outdated
| tries=None, | ||
| num_workers=1, |
| record_ok = dict( | ||
| uuid='f3296986-ded8-11e9-8000-000000000000', | ||
| task='registered_task', | ||
| headers=dict(), | ||
| body=dict(), | ||
| ) | ||
|
|
||
| record_missing_task = dict( | ||
| uuid='t89876702-cas9-22g1-9000-000000000000', | ||
| task='missing_task', | ||
| headers=dict(), | ||
| body=dict(), | ||
| ) |
There was a problem hiding this comment.
Los objetos que se leen de Kinesis tienen la siguiente estructura
https://docs.aws.amazon.com/en_us/kinesis/latest/APIReference/API_Record.html
Sería más apropiado tener esa misma estructura en los objetos del Test
There was a problem hiding this comment.
La idea de la función process_records es qué solo procese esos records.
Puedes ver en el listener que ya solo envía la parte de Data, esto porque SequenceNumber y otros datos no son necesarios para procesar un record, entonces no tiene sentido estarlos enviando por todas las funciones
hub/workers/__init__.py
Outdated
| return workers_created | ||
|
|
||
|
|
||
| def find_decorated_functions(module): |
closes #2
closes #3