/**
 * Data Flow API
 * Use the Data Flow APIs to run any Apache Spark application at any scale without deploying or managing any infrastructure.

 * OpenAPI spec version: 20200129
 *
 *
 * NOTE: This class is auto generated by OracleSDKGenerator.
 * Do not edit the class manually.
 *
 * Copyright (c) 2020, 2022, Oracle and/or its affiliates.  All rights reserved.
 * This software is dual-licensed to you under the Universal Permissive License (UPL) 1.0 as shown at https://oss.oracle.com/licenses/upl or Apache License 2.0 as shown at http://www.apache.org/licenses/LICENSE-2.0. You may choose either license.
 */ import common = require ( "oci-common" ) ; import * as requests from "./request" ; import * as model from "./model" ; import * as responses from "./response" ; import { paginateRecords , paginateResponses } from "oci-common" ; import { DataFlowWaiter } from "./dataflow-waiter" ; import { composeResponse , composeRequest , GenericRetrier } from "oci-common" ; export enum DataFlowApiKeys { } /**
 * This service client uses  common . CircuitBreaker . DefaultConfiguration for all the operations by default if no circuit breaker configuration is defined by the user.
  export class DataFlowClient { protected static serviceEndpointTemplate = "https://dataflow.{region}.oci.{secondLevelDomain}" ; protected "_endpoint" : string = "" ; protected "_defaultHeaders" : any = { } ; protected "_waiters" : DataFlowWaiter ; protected "_clientConfiguration" : common . ClientConfiguration ; protected _circuitBreaker = null ; protected _httpClient : common . HttpClient ; constructor ( params , clientConfiguration ? ) { const requestSigner = params . authenticationDetailsProvider ? new common . DefaultRequestSigner ( params . authenticationDetailsProvider ) : null ; if ( clientConfiguration ) { this . _clientConfiguration = clientConfiguration ; this . _circuitBreaker = clientConfiguration . circuitBreaker ? clientConfiguration . circuitBreaker ! . circuit : null ; } const specCircuitBreakerEnabled = true ; if ( ! this . _circuitBreaker && common . utils . isCircuitBreakerSystemEnabled ( clientConfiguration ! ) && ( specCircuitBreakerEnabled || common . CircuitBreaker . DefaultCircuitBreakerOverriden ) ) { this . _circuitBreaker = new common . CircuitBreaker ( ) . circuit ; } this . _httpClient = params . httpClient || new common . FetchHttpClient ( requestSigner , this . _circuitBreaker ) ; if ( params . authenticationDetailsProvider && common . isRegionProvider ( params . authenticationDetailsProvider ) ) { const provider = params . authenticationDetailsProvider ; if ( provider . getRegion ( ) ) { this . region = provider . getRegion ( ) ; } } } /**
     * Get the endpoint that is being used to call (ex, https://www.example.com).
     */ public get endpoint ( ) { return this . _endpoint ; } param endpoint public set endpoint ( endpoint ) { this . _endpoint = endpoint ; this . _endpoint = this . _endpoint + "/20200129" ; if ( this . logger ) this . logger . info ( `DataFlowClient endpoint set to ${ this . _endpoint }` ) ; } public get logger ( ) { return common . LOG . logger ; } /**
     * Sets the region to call (ex, Region.US_PHOENIX_1).
     * Note, this will call  {@link #endpoint(String) endpoint} after resolving the endpoint.
     *  param region public set region ( region ) { this . endpoint = common . EndpointBuilder . createEndpointFromRegion ( DataFlowClient . serviceEndpointTemplate , region ) ; } /**
     * Sets the regionId to call (ex, 'us-phoenix-1').
     *
     * Note, this will first try to map the region ID to a known Region and call  {@link #region(Region) region} .
     * If no known Region could be determined, it will create an endpoint assuming its in default Realm OC1
     * and then call  {@link #endpoint(String) endpoint} .
     *  param regionId public set regionId ( regionId ) { this . endpoint = common . EndpointBuilder . createEndpointFromRegionId ( DataFlowClient . serviceEndpointTemplate , regionId ) ; } param config return public createWaiters ( config ? ) { this . _waiters = new DataFlowWaiter ( this , config ) ; return this . _waiters ; } return public getWaiters ( ) { if ( this . _waiters ) { return this . _waiters ; } throw Error ( "Waiters do not exist. Please create waiters." ) ; } param ChangeApplicationCompartmentRequest return throws example Click  https to see how to use ChangeApplicationCompartment API.
      public async changeApplicationCompartment ( changeApplicationCompartmentRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#changeApplicationCompartment." ) ; const pathParams = { "{applicationId}" : changeApplicationCompartmentRequest . applicationId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : changeApplicationCompartmentRequest . opcRequestId , "if-match" : changeApplicationCompartmentRequest . ifMatch , "opc-retry-token" : changeApplicationCompartmentRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , changeApplicationCompartmentRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/applications/{applicationId}/actions/changeCompartment" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( changeApplicationCompartmentRequest . changeApplicationCompartmentDetails , "ChangeApplicationCompartmentDetails" , model . ChangeApplicationCompartmentDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ChangeApplicationCompartmentResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ChangePrivateEndpointCompartmentRequest return throws example Click  https to see how to use ChangePrivateEndpointCompartment API.
      public async changePrivateEndpointCompartment ( changePrivateEndpointCompartmentRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#changePrivateEndpointCompartment." ) ; const pathParams = { "{privateEndpointId}" : changePrivateEndpointCompartmentRequest . privateEndpointId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : changePrivateEndpointCompartmentRequest . opcRequestId , "if-match" : changePrivateEndpointCompartmentRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , changePrivateEndpointCompartmentRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/privateEndpoints/{privateEndpointId}/actions/changeCompartment" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( changePrivateEndpointCompartmentRequest . changePrivateEndpointCompartmentDetails , "ChangePrivateEndpointCompartmentDetails" , model . ChangePrivateEndpointCompartmentDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ChangePrivateEndpointCompartmentResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ChangeRunCompartmentRequest return throws example Click  https to see how to use ChangeRunCompartment API.
      public async changeRunCompartment ( changeRunCompartmentRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#changeRunCompartment." ) ; const pathParams = { "{runId}" : changeRunCompartmentRequest . runId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : changeRunCompartmentRequest . opcRequestId , "if-match" : changeRunCompartmentRequest . ifMatch , "opc-retry-token" : changeRunCompartmentRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , changeRunCompartmentRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs/{runId}/actions/changeCompartment" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( changeRunCompartmentRequest . changeRunCompartmentDetails , "ChangeRunCompartmentDetails" , model . ChangeRunCompartmentDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ChangeRunCompartmentResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateApplicationRequest return throws example Click  https to see how to use CreateApplication API.
      public async createApplication ( createApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#createApplication." ) ; const pathParams = { } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createApplicationRequest . opcRetryToken , "opc-request-id" : createApplicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/applications" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createApplicationRequest . createApplicationDetails , "CreateApplicationDetails" , model . CreateApplicationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateApplicationResponse > { } , body : await response . json ( ) , bodyKey : "application" , bodyModel : model . Application , type : "model.Application" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreatePrivateEndpointRequest return throws example Click  https to see how to use CreatePrivateEndpoint API.
      public async createPrivateEndpoint ( createPrivateEndpointRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#createPrivateEndpoint." ) ; const pathParams = { } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createPrivateEndpointRequest . opcRetryToken , "opc-request-id" : createPrivateEndpointRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createPrivateEndpointRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/privateEndpoints" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createPrivateEndpointRequest . createPrivateEndpointDetails , "CreatePrivateEndpointDetails" , model . CreatePrivateEndpointDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreatePrivateEndpointResponse > { } , body : await response . json ( ) , bodyKey : "privateEndpoint" , bodyModel : model . PrivateEndpoint , type : "model.PrivateEndpoint" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } , { value : response . headers . get ( "Location" ) , key : "location" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateRunRequest return throws example Click  https to see how to use CreateRun API.
      public async createRun ( createRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#createRun." ) ; const pathParams = { } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createRunRequest . opcRetryToken , "opc-request-id" : createRunRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createRunRequest . createRunDetails , "CreateRunDetails" , model . CreateRunDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateRunResponse > { } , body : await response . json ( ) , bodyKey : "run" , bodyModel : model . Run , type : "model.Run" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteApplicationRequest return throws example Click  https to see how to use DeleteApplication API.
      public async deleteApplication ( deleteApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#deleteApplication." ) ; const pathParams = { "{applicationId}" : deleteApplicationRequest . applicationId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : deleteApplicationRequest . opcRequestId , "if-match" : deleteApplicationRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/applications/{applicationId}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteApplicationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeletePrivateEndpointRequest return throws example Click  https to see how to use DeletePrivateEndpoint API.
      public async deletePrivateEndpoint ( deletePrivateEndpointRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#deletePrivateEndpoint." ) ; const pathParams = { "{privateEndpointId}" : deletePrivateEndpointRequest . privateEndpointId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : deletePrivateEndpointRequest . opcRequestId , "if-match" : deletePrivateEndpointRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deletePrivateEndpointRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/privateEndpoints/{privateEndpointId}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeletePrivateEndpointResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteRunRequest return throws example Click  https to see how to use DeleteRun API.
      public async deleteRun ( deleteRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#deleteRun." ) ; const pathParams = { "{runId}" : deleteRunRequest . runId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : deleteRunRequest . opcRequestId , "if-match" : deleteRunRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs/{runId}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteRunResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetApplicationRequest return throws example Click  https to see how to use GetApplication API.
      public async getApplication ( getApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#getApplication." ) ; const pathParams = { "{applicationId}" : getApplicationRequest . applicationId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getApplicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/applications/{applicationId}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetApplicationResponse > { } , body : await response . json ( ) , bodyKey : "application" , bodyModel : model . Application , type : "model.Application" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetPrivateEndpointRequest return throws example Click  https to see how to use GetPrivateEndpoint API.
      public async getPrivateEndpoint ( getPrivateEndpointRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#getPrivateEndpoint." ) ; const pathParams = { "{privateEndpointId}" : getPrivateEndpointRequest . privateEndpointId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getPrivateEndpointRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getPrivateEndpointRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/privateEndpoints/{privateEndpointId}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetPrivateEndpointResponse > { } , body : await response . json ( ) , bodyKey : "privateEndpoint" , bodyModel : model . PrivateEndpoint , type : "model.PrivateEndpoint" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetRunRequest return throws example Click  https to see how to use GetRun API.
      public async getRun ( getRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#getRun." ) ; const pathParams = { "{runId}" : getRunRequest . runId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getRunRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs/{runId}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetRunResponse > { } , body : await response . json ( ) , bodyKey : "run" , bodyModel : model . Run , type : "model.Run" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetRunLogRequest return throws example Click  https to see how to use GetRunLog API.
      public async getRunLog ( getRunLogRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#getRunLog." ) ; const pathParams = { "{runId}" : getRunLogRequest . runId , "{name}" : getRunLogRequest . name } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getRunLogRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getRunLogRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs/{runId}/logs/{name}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetRunLogResponse > { } , body : response . body ! , bodyKey : "value" , bodyModel : "string" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "content-length" ) , key : "contentLength" , dataType : "number" } , { value : response . headers . get ( "content-type" ) , key : "contentType" , dataType : "string" } , { value : response . headers . get ( "content-encoding" ) , key : "contentEncoding" , dataType : "string" } ] } ) ; const opcMeta = { } ; const pattern = "opc-meta-" ; response . headers . forEach ( ( v , k ) => { if ( k . startsWith ( pattern ) ) { Object . assign ( opcMeta , { [ k ] : v } ) ; } } ) ; sdkResponse . opcMeta = opcMeta ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetWorkRequestRequest return throws example Click  https to see how to use GetWorkRequest API.
      public async getWorkRequest ( getWorkRequestRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#getWorkRequest." ) ; const pathParams = { "{workRequestId}" : getWorkRequestRequest . workRequestId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getWorkRequestRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getWorkRequestRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests/{workRequestId}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetWorkRequestResponse > { } , body : await response . json ( ) , bodyKey : "workRequest" , bodyModel : model . WorkRequest , type : "model.WorkRequest" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListApplicationsRequest return throws example Click  https to see how to use ListApplications API.
      public async listApplications ( listApplicationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listApplications." ) ; const pathParams = { } ; const queryParams = { "compartmentId" : listApplicationsRequest . compartmentId , "limit" : listApplicationsRequest . limit , "page" : listApplicationsRequest . page , "sortBy" : listApplicationsRequest . sortBy , "sortOrder" : listApplicationsRequest . sortOrder , "displayName" : listApplicationsRequest . displayName , "ownerPrincipalId" : listApplicationsRequest . ownerPrincipalId , "displayNameStartsWith" : listApplicationsRequest . displayNameStartsWith , "sparkVersion" : listApplicationsRequest . sparkVersion } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listApplicationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listApplicationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/applications" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListApplicationsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . ApplicationSummary , type : "Array<model.ApplicationSummary>" , responseHeaders : [ { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllApplications ( request ) { return paginateRecords ( request , req => this . listApplications ( req ) ) ; } param request public listAllApplicationsResponses ( request ) { return paginateResponses ( request , req => this . listApplications ( req ) ) ; } param request public listApplicationsRecordIterator ( request ) { return paginateRecords ( request , req => this . listApplications ( req ) ) ; } param request public listApplicationsResponseIterator ( request ) { return paginateResponses ( request , req => this . listApplications ( req ) ) ; } param ListPrivateEndpointsRequest return throws example Click  https to see how to use ListPrivateEndpoints API.
      public async listPrivateEndpoints ( listPrivateEndpointsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listPrivateEndpoints." ) ; const pathParams = { } ; const queryParams = { "compartmentId" : listPrivateEndpointsRequest . compartmentId , "limit" : listPrivateEndpointsRequest . limit , "page" : listPrivateEndpointsRequest . page , "lifecycleState" : listPrivateEndpointsRequest . lifecycleState , "sortBy" : listPrivateEndpointsRequest . sortBy , "sortOrder" : listPrivateEndpointsRequest . sortOrder , "displayName" : listPrivateEndpointsRequest . displayName , "ownerPrincipalId" : listPrivateEndpointsRequest . ownerPrincipalId , "displayNameStartsWith" : listPrivateEndpointsRequest . displayNameStartsWith } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listPrivateEndpointsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listPrivateEndpointsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/privateEndpoints" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListPrivateEndpointsResponse > { } , body : await response . json ( ) , bodyKey : "privateEndpointCollection" , bodyModel : model . PrivateEndpointCollection , type : "model.PrivateEndpointCollection" , responseHeaders : [ { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListRunLogsRequest return throws example Click  https to see how to use ListRunLogs API.
      public async listRunLogs ( listRunLogsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listRunLogs." ) ; const pathParams = { "{runId}" : listRunLogsRequest . runId } ; const queryParams = { "limit" : listRunLogsRequest . limit , "page" : listRunLogsRequest . page } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listRunLogsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listRunLogsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs/{runId}/logs" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListRunLogsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . RunLogSummary , type : "Array<model.RunLogSummary>" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllRunLogs ( request ) { return paginateRecords ( request , req => this . listRunLogs ( req ) ) ; } param request public listAllRunLogsResponses ( request ) { return paginateResponses ( request , req => this . listRunLogs ( req ) ) ; } param request public listRunLogsRecordIterator ( request ) { return paginateRecords ( request , req => this . listRunLogs ( req ) ) ; } param request public listRunLogsResponseIterator ( request ) { return paginateResponses ( request , req => this . listRunLogs ( req ) ) ; } param ListRunsRequest return throws example Click  https to see how to use ListRuns API.
      public async listRuns ( listRunsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listRuns." ) ; const pathParams = { } ; const queryParams = { "compartmentId" : listRunsRequest . compartmentId , "applicationId" : listRunsRequest . applicationId , "ownerPrincipalId" : listRunsRequest . ownerPrincipalId , "displayNameStartsWith" : listRunsRequest . displayNameStartsWith , "lifecycleState" : listRunsRequest . lifecycleState , "timeCreatedGreaterThan" : listRunsRequest . timeCreatedGreaterThan , "limit" : listRunsRequest . limit , "page" : listRunsRequest . page , "sortBy" : listRunsRequest . sortBy , "sortOrder" : listRunsRequest . sortOrder , "displayName" : listRunsRequest . displayName } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listRunsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listRunsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListRunsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . RunSummary , type : "Array<model.RunSummary>" , responseHeaders : [ { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllRuns ( request ) { return paginateRecords ( request , req => this . listRuns ( req ) ) ; } param request public listAllRunsResponses ( request ) { return paginateResponses ( request , req => this . listRuns ( req ) ) ; } param request public listRunsRecordIterator ( request ) { return paginateRecords ( request , req => this . listRuns ( req ) ) ; } param request public listRunsResponseIterator ( request ) { return paginateResponses ( request , req => this . listRuns ( req ) ) ; } param ListWorkRequestErrorsRequest return throws example Click  https to see how to use ListWorkRequestErrors API.
      public async listWorkRequestErrors ( listWorkRequestErrorsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listWorkRequestErrors." ) ; const pathParams = { "{workRequestId}" : listWorkRequestErrorsRequest . workRequestId } ; const queryParams = { "limit" : listWorkRequestErrorsRequest . limit , "page" : listWorkRequestErrorsRequest . page } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkRequestErrorsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkRequestErrorsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests/{workRequestId}/errors" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkRequestErrorsResponse > { } , body : await response . json ( ) , bodyKey : "workRequestErrorCollection" , bodyModel : model . WorkRequestErrorCollection , type : "model.WorkRequestErrorCollection" , responseHeaders : [ { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListWorkRequestLogsRequest return throws example Click  https to see how to use ListWorkRequestLogs API.
      public async listWorkRequestLogs ( listWorkRequestLogsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listWorkRequestLogs." ) ; const pathParams = { "{workRequestId}" : listWorkRequestLogsRequest . workRequestId } ; const queryParams = { "limit" : listWorkRequestLogsRequest . limit , "page" : listWorkRequestLogsRequest . page } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkRequestLogsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkRequestLogsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests/{workRequestId}/logs" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkRequestLogsResponse > { } , body : await response . json ( ) , bodyKey : "workRequestLogCollection" , bodyModel : model . WorkRequestLogCollection , type : "model.WorkRequestLogCollection" , responseHeaders : [ { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListWorkRequestsRequest return throws example Click  https to see how to use ListWorkRequests API.
      public async listWorkRequests ( listWorkRequestsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#listWorkRequests." ) ; const pathParams = { } ; const queryParams = { "compartmentId" : listWorkRequestsRequest . compartmentId , "limit" : listWorkRequestsRequest . limit , "page" : listWorkRequestsRequest . page } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkRequestsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkRequestsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkRequestsResponse > { } , body : await response . json ( ) , bodyKey : "workRequestCollection" , bodyModel : model . WorkRequestCollection , type : "model.WorkRequestCollection" , responseHeaders : [ { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateApplicationRequest return throws example Click  https to see how to use UpdateApplication API.
      public async updateApplication ( updateApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#updateApplication." ) ; const pathParams = { "{applicationId}" : updateApplicationRequest . applicationId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateApplicationRequest . opcRequestId , "if-match" : updateApplicationRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/applications/{applicationId}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateApplicationRequest . updateApplicationDetails , "UpdateApplicationDetails" , model . UpdateApplicationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateApplicationResponse > { } , body : await response . json ( ) , bodyKey : "application" , bodyModel : model . Application , type : "model.Application" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdatePrivateEndpointRequest return throws example Click  https to see how to use UpdatePrivateEndpoint API.
      public async updatePrivateEndpoint ( updatePrivateEndpointRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#updatePrivateEndpoint." ) ; const pathParams = { "{privateEndpointId}" : updatePrivateEndpointRequest . privateEndpointId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updatePrivateEndpointRequest . opcRequestId , "if-match" : updatePrivateEndpointRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updatePrivateEndpointRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/privateEndpoints/{privateEndpointId}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updatePrivateEndpointRequest . updatePrivateEndpointDetails , "UpdatePrivateEndpointDetails" , model . UpdatePrivateEndpointDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdatePrivateEndpointResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateRunRequest return throws example Click  https to see how to use UpdateRun API.
      public async updateRun ( updateRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataFlowClient#updateRun." ) ; const pathParams = { "{runId}" : updateRunRequest . runId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateRunRequest . opcRequestId , "if-match" : updateRunRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/runs/{runId}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateRunRequest . updateRunDetails , "UpdateRunDetails" , model . UpdateRunDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateRunResponse > { } , body : await response . json ( ) , bodyKey : "run" , bodyModel : model . Run , type : "model.Run" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } }