public Flux<CosmosContainerProperties> queryContainers(
            final String query, final CosmosQueryRequestOptions queryRequestOptions) {
        CosmosDbUtils.validateIfParameterIsNotEmpty(query, PARAM_QUERY);

        return database
                .flatMapMany(database -> CosmosDbUtils
                        .convertCosmosPagedFluxToFluxResults(database.queryContainers(query, queryRequestOptions)));
    }
@Test
    void testQueryContainers() {
        final CosmosAsyncDatabase database = mock(CosmosAsyncDatabase.class);

        final CosmosDbDatabaseOperations databaseOperations = new CosmosDbDatabaseOperations(Mono.just(database));

        CosmosDbTestUtils.assertIllegalArgumentException(() -> databaseOperations.queryContainers(null, null));
        CosmosDbTestUtils.assertIllegalArgumentException(() -> databaseOperations.queryContainers("", null));
    }