(ch, method, properties, body)
| 18 | channel = connection.channel() |
| 19 | |
| 20 | def callback(ch, method, properties, body): |
| 21 | err = to_mp3.start(body, fs_videos, fs_mp3s, ch) |
| 22 | if err: |
| 23 | ch.basic_nack(delivery_tag=method.delivery_tag) |
| 24 | else: |
| 25 | ch.basic_ack(delivery_tag=method.delivery_tag) |
| 26 | |
| 27 | channel.basic_consume( |
| 28 | queue=os.environ.get("VIDEO_QUEUE"), on_message_callback=callback |
nothing calls this directly
no outgoing calls
no test coverage detected