## Get Pipeline Data Source Status

`ManagedIngestionStatusResponse pipelines().dataSources().getStatus(DataSourceGetStatusParamsparams, RequestOptionsrequestOptions = RequestOptions.none())`

**get** `/api/v1/pipelines/{pipeline_id}/data-sources/{data_source_id}/status`

Get the status of a data source for a pipeline.

### Parameters

- `DataSourceGetStatusParams params`

  - `String pipelineId`

  - `Optional<String> dataSourceId`

### Returns

- `class ManagedIngestionStatusResponse:`

  - `Status status`

    Status of the ingestion.

    - `NOT_STARTED("NOT_STARTED")`

    - `IN_PROGRESS("IN_PROGRESS")`

    - `SUCCESS("SUCCESS")`

    - `ERROR("ERROR")`

    - `PARTIAL_SUCCESS("PARTIAL_SUCCESS")`

    - `CANCELLED("CANCELLED")`

  - `Optional<LocalDateTime> deploymentDate`

    Date of the deployment.

  - `Optional<LocalDateTime> effectiveAt`

    When the status is effective

  - `Optional<List<Error>> error`

    List of errors that occurred during ingestion.

    - `String jobId`

      ID of the job that failed.

    - `String message`

      List of errors that occurred during ingestion.

    - `Step step`

      Name of the job that failed.

      - `MANAGED_INGESTION("MANAGED_INGESTION")`

      - `DATA_SOURCE("DATA_SOURCE")`

      - `FILE_UPDATER("FILE_UPDATER")`

      - `PARSE("PARSE")`

      - `TRANSFORM("TRANSFORM")`

      - `INGESTION("INGESTION")`

      - `METADATA_UPDATE("METADATA_UPDATE")`

  - `Optional<String> jobId`

    ID of the latest job.

### Example

```java
package com.llamacloud_prod.api.example;

import com.llamacloud_prod.api.client.LlamaCloudClient;
import com.llamacloud_prod.api.client.okhttp.LlamaCloudOkHttpClient;
import com.llamacloud_prod.api.models.pipelines.ManagedIngestionStatusResponse;
import com.llamacloud_prod.api.models.pipelines.datasources.DataSourceGetStatusParams;

public final class Main {
    private Main() {}

    public static void main(String[] args) {
        LlamaCloudClient client = LlamaCloudOkHttpClient.fromEnv();

        DataSourceGetStatusParams params = DataSourceGetStatusParams.builder()
            .pipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e")
            .dataSourceId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e")
            .build();
        ManagedIngestionStatusResponse managedIngestionStatusResponse = client.pipelines().dataSources().getStatus(params);
    }
}
```

#### Response

```json
{
  "status": "NOT_STARTED",
  "deployment_date": "2019-12-27T18:11:19.117Z",
  "effective_at": "2019-12-27T18:11:19.117Z",
  "error": [
    {
      "job_id": "182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e",
      "message": "message",
      "step": "MANAGED_INGESTION"
    }
  ],
  "job_id": "182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e"
}
```