def METHOD_NAME(result_pub, count) -> None:
    for i in range(count):
        message = {
            "task_id": str(uuid.uuid4()),
            "result": f"foo-{i}",
        }
        b_message = json.dumps(message).encode()
        result_pub.publish(b_message)
    logging.warning(f"Published {count} messages")