async def METHOD_NAME(app: FastAPI):
    settings: ApplicationSettings = _get_settings(app)
    shared_store: SharedStore = app.state.shared_store
    container_states: dict[str, ContainerState | None] = await get_container_states(
        shared_store.container_names
    )
    if are_all_containers_in_expected_states(container_states.values()):
        message = RabbitResourceTrackingHeartbeatMessage(
            service_run_id=settings.DY_SIDECAR_RUN_ID
        )
        await post_resource_tracking_message(app, message)
    else:
        _logger.info(
            "heart beat message skipped: container_states=%s", container_states
        )