postRunEvent
Send an event related to the state of a run
Updates a run state for a job.
/lineage
Usage and SDK Samples
curl -X POST\
-H "Content-Type: application/json"\
"http://localhost/lineage"
import org.openapitools.client.*;
import org.openapitools.client.auth.*;
import org.openapitools.client.model.*;
import org.openapitools.client.api.OpenLineageApi;
import java.io.File;
import java.util.*;
public class OpenLineageApiExample {
public static void main(String[] args) {
// Create an instance of the API class
OpenLineageApi apiInstance = new OpenLineageApi();
RunEvent runEvent = ; // RunEvent |
try {
apiInstance.postRunEvent(runEvent);
} catch (ApiException e) {
System.err.println("Exception when calling OpenLineageApi#postRunEvent");
e.printStackTrace();
}
}
}
import org.openapitools.client.api.OpenLineageApi;
public class OpenLineageApiExample {
public static void main(String[] args) {
OpenLineageApi apiInstance = new OpenLineageApi();
RunEvent runEvent = ; // RunEvent |
try {
apiInstance.postRunEvent(runEvent);
} catch (ApiException e) {
System.err.println("Exception when calling OpenLineageApi#postRunEvent");
e.printStackTrace();
}
}
}
// Create an instance of the API class
OpenLineageApi *apiInstance = [[OpenLineageApi alloc] init];
RunEvent *runEvent = ; // (optional)
// Send an event related to the state of a run
[apiInstance postRunEventWith:runEvent
completionHandler: ^(NSError* error) {
if (error) {
NSLog(@"Error: %@", error);
}
}];
var OpenLineage = require('open_lineage');
// Create an instance of the API class
var api = new OpenLineage.OpenLineageApi()
var opts = {
'runEvent': // {RunEvent}
};
var callback = function(error, data, response) {
if (error) {
console.error(error);
} else {
console.log('API called successfully.');
}
};
api.postRunEvent(opts, callback);
using System;
using System.Diagnostics;
using Org.OpenAPITools.Api;
using Org.OpenAPITools.Client;
using Org.OpenAPITools.Model;
namespace Example
{
public class postRunEventExample
{
public void main()
{
// Create an instance of the API class
var apiInstance = new OpenLineageApi();
var runEvent = new RunEvent(); // RunEvent | (optional)
try {
// Send an event related to the state of a run
apiInstance.postRunEvent(runEvent);
} catch (Exception e) {
Debug.Print("Exception when calling OpenLineageApi.postRunEvent: " + e.Message );
}
}
}
}
<?php
require_once(__DIR__ . '/vendor/autoload.php');
// Create an instance of the API class
$api_instance = new OpenAPITools\Client\Api\OpenLineageApi();
$runEvent = ; // RunEvent |
try {
$api_instance->postRunEvent($runEvent);
} catch (Exception $e) {
echo 'Exception when calling OpenLineageApi->postRunEvent: ', $e->getMessage(), PHP_EOL;
}
?>
use Data::Dumper;
use WWW::OPenAPIClient::Configuration;
use WWW::OPenAPIClient::OpenLineageApi;
# Create an instance of the API class
my $api_instance = WWW::OPenAPIClient::OpenLineageApi->new();
my $runEvent = WWW::OPenAPIClient::Object::RunEvent->new(); # RunEvent |
eval {
$api_instance->postRunEvent(runEvent => $runEvent);
};
if ($@) {
warn "Exception when calling OpenLineageApi->postRunEvent: $@\n";
}
from __future__ import print_statement
import time
import openapi_client
from openapi_client.rest import ApiException
from pprint import pprint
# Create an instance of the API class
api_instance = openapi_client.OpenLineageApi()
runEvent = # RunEvent | (optional)
try:
# Send an event related to the state of a run
api_instance.post_run_event(runEvent=runEvent)
except ApiException as e:
print("Exception when calling OpenLineageApi->postRunEvent: %s\n" % e)
extern crate OpenLineageApi;
pub fn main() {
let runEvent = ; // RunEvent
let mut context = OpenLineageApi::Context::default();
let result = client.postRunEvent(runEvent, &context).wait();
println!("{:?}", result);
}
Scopes
Parameters
Body parameters
Name | Description |
---|---|
runEvent |