/**
 * Test for ModelSource interface and its implementations.
 */
class ModelSourceTest {

    @Test
    void testBuildSourceHasNoModelId() {
        Path path = Paths.get("/tmp/pom.xml");
        ModelSource source = Sources.buildSource(path);

        assertNotNull(source);
        assertNull(source.getModelId(), "Build sources should not have a modelId");

app = FastAPI()


def get_db():
    db = DBSession()
    try:
        yield db
    finally:
        db.close()


DBDep = Annotated[DBSession, Depends(get_db)]


@app.get("/items/")
async def read_items(db: DBDep):
    return db.query(Item).all()
```

     * @param body the search body containing pagination and filter parameters
     * @return JSON response containing list of synonym dictionary items
     */
    // GET /api/admin/dict/synonym/settings/{dictId}
    @Execute
    public JsonResponse<ApiResult> get$settings(final String dictId, final SearchBody body) {
        body.dictId = dictId;
        validateApi(body, messages -> {});

    }
    return elements.get(0);
  }

  @Override
  public E last() {
    if (isEmpty()) {
      throw new NoSuchElementException();
    }
    return elements.get(size() - 1);
  }

  @Override
  public @Nullable E lower(E element) {
    int index = headIndex(element, false) - 1;
    return (index == -1) ? null : elements.get(index);
  }

  @Override

    testDistribution = providers.systemProperty('run.distribution').orElse('default').forUseAtConfigurationTime().get()
    if (providers.systemProperty('run.distribution').orElse('default').forUseAtConfigurationTime().get() == 'default') {
      String licenseType = providers.systemProperty("run.license_type").orElse("basic").forUseAtConfigurationTime().get()
      if (licenseType == 'trial') {
        setting 'xpack.ml.enabled', 'true'

		return args, err
	}

	pluginURL := env.Get(EnvIdentityPluginURL, kv.Get(URL))
	if pluginURL == "" {
		return args, nil
	}

	authToken := env.Get(EnvIdentityPluginAuthToken, kv.Get(AuthToken))

	u, err := xnet.ParseHTTPURL(pluginURL)
	if err != nil {
		return args, err
	}

	rolePolicy := env.Get(EnvIdentityPluginRolePolicy, kv.Get(RolePolicy))
	if rolePolicy == "" {

        modelIds.add(modelId);

        return this;
    }

    @Override
    public Model getRawModel() {
        return rawModels.get(modelIds.get(0));
    }

    @Override
    public Model getRawModel(String modelId) {
        return rawModels.get(modelId);
    }

    public DefaultModelBuildingResult setRawModel(String modelId, Model rawModel) {

        Assertions.assertEquals("yes it is", invokerRequest.userProperties().get("user.property"));

        // maven installation
        Assertions.assertTrue(invokerRequest.systemProperties().containsKey("maven.property"));
        Assertions.assertEquals("yes it is", invokerRequest.systemProperties().get("maven.property"));
    }

    @Test
    void notHappy() {

  @Override
  protected abstract LoadingCache<K, V> delegate();

  @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
  @Override
  public V get(K key) throws ExecutionException {
    return delegate().get(key);
  }

  @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
  @Override
  public V getUnchecked(K key) {
    return delegate().getUnchecked(key);
  }

def test_openapi_schema(client: TestClient):
    response = client.get("/openapi.json")
    assert response.status_code == 200, response.text
    assert response.json() == snapshot(
        {
            "openapi": "3.1.0",
            "info": {"title": "FastAPI", "version": "0.1.0"},
            "paths": {
                "/items/{item_id}": {
                    "get": {
                        "responses": {