async def METHOD_NAME(
    disable_clusters_management_background_task: None,
    _base_configuration: None,
    ec2_client: EC2Client,
    user_id: UserID,
    wallet_id: WalletID,
    initialized_app: FastAPI,
    mocked_dask_ping_gateway: MockedDaskModule,
):
    created_clusters = await create_cluster(
        initialized_app, user_id=user_id, wallet_id=wallet_id
    )
    assert len(created_clusters) == 1
    # running the cluster management task shall not remove anything
    await check_clusters(initialized_app)
    await _assert_cluster_exist_and_state(
        ec2_client, instances=created_clusters, state="running"
    )
    mocked_dask_ping_gateway.ping_gateway.assert_called_once()
    mocked_dask_ping_gateway.ping_gateway.reset_mock()
    mocked_dask_ping_gateway.is_gateway_busy.assert_called_once()
    mocked_dask_ping_gateway.is_gateway_busy.reset_mock()
    # running the cluster management task after the heartbeat came in shall not remove anything
    await asyncio.sleep(_FAST_TIME_BEFORE_TERMINATION_SECONDS + 1)
    await cluster_heartbeat(initialized_app, user_id=user_id, wallet_id=wallet_id)
    await check_clusters(initialized_app)
    await _assert_cluster_exist_and_state(
        ec2_client, instances=created_clusters, state="running"
    )
    mocked_dask_ping_gateway.ping_gateway.assert_called_once()
    mocked_dask_ping_gateway.ping_gateway.reset_mock()
    mocked_dask_ping_gateway.is_gateway_busy.assert_called_once()
    mocked_dask_ping_gateway.is_gateway_busy.reset_mock()
    # after waiting the termination time, running the task shall remove the cluster
    await asyncio.sleep(_FAST_TIME_BEFORE_TERMINATION_SECONDS + 1)
    await check_clusters(initialized_app)
    await _assert_cluster_exist_and_state(
        ec2_client, instances=created_clusters, state="terminated"
    )
    mocked_dask_ping_gateway.ping_gateway.assert_called_once()
    mocked_dask_ping_gateway.is_gateway_busy.assert_called_once()