Pipeline Weight Bags: A Reliable Solution for Anti-Buoyancy Challenges

 Fetching Pipeline Execution Details in Oracle EPM Using Groovy!

In Oracle EPM, pipelines are essential for automating data workflows, integrating data sources, and performing transformations. To ensure smooth execution, it's crucial to monitor pipeline runs and detect job failures in real-time.

When running automated data processing or calculations in Oracle EPM Cloud, monitoring the execution status of pipelines is critical. You don’t want to just trigger a pipeline and hope for the best—you need real-time insights into whether jobs succeed or fail.

This blog post explains how a Groovy script fetches pipeline execution details using Oracle EPM’s REST API and processes job statuses to determine if any failures have occurred.

 

The script retrieves execution details for a specific pipeline and checks the status of individual jobs within the pipeline. If any job fails, the script aborts execution and raises an error.

 

Fetch Pipeline Execution Details from REST API

The script initiates an HTTP GET request to Oracle EPM’s REST API to fetch pipeline execution details.

 

Making the API Call - https://yourhost.oraclecloud.com/aif/rest/V1/pipeline?pipelineName=PipelineCode

This is an undocumented feature for your information.

 

More info on this and the idea created is here -   

https://community.oracle.com/customerconnect/discussion/842635/pipeline-child-jobs-monitoring-via-groovy-restapi

 

Imagine you’re running a forecast data load pipeline called SFCLCFCSTLOAD. This pipeline consists of multiple stages and jobs that need to execute in sequence (or in parallel). But what if one of those jobs fails?

# You need to detect failures early.

# You need to log the details of every job in the pipeline.

# You need to abort execution if something goes wrong.

This script does exactly that! Let’s break it down step by step.

 

 # Making a REST API Call to Fetch Pipeline Details

The script starts by making an HTTP GET request to the Oracle EPM pipeline API to retrieve details of the SFCLCFCSTLOAD pipeline.

groovy

 

try {

    HttpResponse<String> PipeResponse = operation.application.getConnection("localURL")

        .get('/aif/rest/V1/pipeline?pipelineName=PipelineName')

        .asString()

 

 

# Handling the API Response

Before processing the response, we check for null values to avoid unexpected errors.

 

if (PipeResponse == null || PipeResponse.body == null) {

    throwVetoException("Error: Received null response for pipeline execution.")