Data Lineage v1 API - Class LineageClient (1.3.0)

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
BatchSearchLinkProcessesRequest request = new BatchSearchLinkProcessesRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Links = { "", },
};
// Make the request
PagedEnumerable<BatchSearchLinkProcessesResponse, ProcessLinks> response = lineageClient.BatchSearchLinkProcesses(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (ProcessLinks item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (BatchSearchLinkProcessesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (ProcessLinks item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<ProcessLinks> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (ProcessLinks item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
BatchSearchLinkProcessesRequest request = new BatchSearchLinkProcessesRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Links = { "", },
};
// Make the request
PagedAsyncEnumerable<BatchSearchLinkProcessesResponse, ProcessLinks> response = lineageClient.BatchSearchLinkProcessesAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((ProcessLinks item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((BatchSearchLinkProcessesResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (ProcessLinks item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<ProcessLinks> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (ProcessLinks item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
CreateLineageEventRequest request = new CreateLineageEventRequest
{
    ParentAsRunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
    LineageEvent = new LineageEvent(),
    RequestId = "",
};
// Make the request
LineageEvent response = lineageClient.CreateLineageEvent(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
RunName parent = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
LineageEvent lineageEvent = new LineageEvent();
// Make the request
LineageEvent response = lineageClient.CreateLineageEvent(parent, lineageEvent);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
LineageEvent lineageEvent = new LineageEvent();
// Make the request
LineageEvent response = lineageClient.CreateLineageEvent(parent, lineageEvent);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
CreateLineageEventRequest request = new CreateLineageEventRequest
{
    ParentAsRunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
    LineageEvent = new LineageEvent(),
    RequestId = "",
};
// Make the request
LineageEvent response = await lineageClient.CreateLineageEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
CreateLineageEventRequest request = new CreateLineageEventRequest
{
    ParentAsRunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
    LineageEvent = new LineageEvent(),
    RequestId = "",
};
// Make the request
LineageEvent response = await lineageClient.CreateLineageEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName parent = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
LineageEvent lineageEvent = new LineageEvent();
// Make the request
LineageEvent response = await lineageClient.CreateLineageEventAsync(parent, lineageEvent);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName parent = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
LineageEvent lineageEvent = new LineageEvent();
// Make the request
LineageEvent response = await lineageClient.CreateLineageEventAsync(parent, lineageEvent);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
LineageEvent lineageEvent = new LineageEvent();
// Make the request
LineageEvent response = await lineageClient.CreateLineageEventAsync(parent, lineageEvent);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
LineageEvent lineageEvent = new LineageEvent();
// Make the request
LineageEvent response = await lineageClient.CreateLineageEventAsync(parent, lineageEvent);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Process process = new Process();
// Make the request
Process response = lineageClient.CreateProcess(parent, process);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
CreateProcessRequest request = new CreateProcessRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Process = new Process(),
    RequestId = "",
};
// Make the request
Process response = lineageClient.CreateProcess(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Process process = new Process();
// Make the request
Process response = lineageClient.CreateProcess(parent, process);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Process process = new Process();
// Make the request
Process response = await lineageClient.CreateProcessAsync(parent, process);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Process process = new Process();
// Make the request
Process response = await lineageClient.CreateProcessAsync(parent, process);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
CreateProcessRequest request = new CreateProcessRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Process = new Process(),
    RequestId = "",
};
// Make the request
Process response = await lineageClient.CreateProcessAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
CreateProcessRequest request = new CreateProcessRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Process = new Process(),
    RequestId = "",
};
// Make the request
Process response = await lineageClient.CreateProcessAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Process process = new Process();
// Make the request
Process response = await lineageClient.CreateProcessAsync(parent, process);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Process process = new Process();
// Make the request
Process response = await lineageClient.CreateProcessAsync(parent, process);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
CreateRunRequest request = new CreateRunRequest
{
    ParentAsProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
    Run = new Run(),
    RequestId = "",
};
// Make the request
Run response = lineageClient.CreateRun(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ProcessName parent = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
Run run = new Run();
// Make the request
Run response = lineageClient.CreateRun(parent, run);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
Run run = new Run();
// Make the request
Run response = lineageClient.CreateRun(parent, run);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
CreateRunRequest request = new CreateRunRequest
{
    ParentAsProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
    Run = new Run(),
    RequestId = "",
};
// Make the request
Run response = await lineageClient.CreateRunAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
CreateRunRequest request = new CreateRunRequest
{
    ParentAsProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
    Run = new Run(),
    RequestId = "",
};
// Make the request
Run response = await lineageClient.CreateRunAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName parent = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
Run run = new Run();
// Make the request
Run response = await lineageClient.CreateRunAsync(parent, run);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName parent = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
Run run = new Run();
// Make the request
Run response = await lineageClient.CreateRunAsync(parent, run);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
Run run = new Run();
// Make the request
Run response = await lineageClient.CreateRunAsync(parent, run);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
Run run = new Run();
// Make the request
Run response = await lineageClient.CreateRunAsync(parent, run);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
DeleteLineageEventRequest request = new DeleteLineageEventRequest
{
    LineageEventName = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]"),
    AllowMissing = false,
};
// Make the request
lineageClient.DeleteLineageEvent(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
LineageEventName name = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
// Make the request
lineageClient.DeleteLineageEvent(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]/lineageEvents/[LINEAGE_EVENT]";
// Make the request
lineageClient.DeleteLineageEvent(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
DeleteLineageEventRequest request = new DeleteLineageEventRequest
{
    LineageEventName = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]"),
    AllowMissing = false,
};
// Make the request
await lineageClient.DeleteLineageEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
DeleteLineageEventRequest request = new DeleteLineageEventRequest
{
    LineageEventName = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]"),
    AllowMissing = false,
};
// Make the request
await lineageClient.DeleteLineageEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LineageEventName name = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
// Make the request
await lineageClient.DeleteLineageEventAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LineageEventName name = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
// Make the request
await lineageClient.DeleteLineageEventAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]/lineageEvents/[LINEAGE_EVENT]";
// Make the request
await lineageClient.DeleteLineageEventAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]/lineageEvents/[LINEAGE_EVENT]";
// Make the request
await lineageClient.DeleteLineageEventAsync(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
DeleteProcessRequest request = new DeleteProcessRequest
{
    ProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
    AllowMissing = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = lineageClient.DeleteProcess(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = lineageClient.PollOnceDeleteProcess(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ProcessName name = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
Operation<Empty, OperationMetadata> response = lineageClient.DeleteProcess(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = lineageClient.PollOnceDeleteProcess(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
Operation<Empty, OperationMetadata> response = lineageClient.DeleteProcess(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = lineageClient.PollOnceDeleteProcess(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
DeleteProcessRequest request = new DeleteProcessRequest
{
    ProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
    AllowMissing = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteProcessAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteProcessAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
DeleteProcessRequest request = new DeleteProcessRequest
{
    ProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
    AllowMissing = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteProcessAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteProcessAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName name = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteProcessAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteProcessAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName name = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteProcessAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteProcessAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteProcessAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteProcessAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteProcessAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteProcessAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
DeleteRunRequest request = new DeleteRunRequest
{
    RunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
    AllowMissing = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = lineageClient.DeleteRun(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = lineageClient.PollOnceDeleteRun(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
RunName name = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
Operation<Empty, OperationMetadata> response = lineageClient.DeleteRun(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = lineageClient.PollOnceDeleteRun(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
Operation<Empty, OperationMetadata> response = lineageClient.DeleteRun(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = lineageClient.PollOnceDeleteRun(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
DeleteRunRequest request = new DeleteRunRequest
{
    RunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
    AllowMissing = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteRunAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteRunAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
DeleteRunRequest request = new DeleteRunRequest
{
    RunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
    AllowMissing = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteRunAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteRunAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName name = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteRunAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteRunAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName name = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteRunAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteRunAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteRunAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteRunAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
Operation<Empty, OperationMetadata> response = await lineageClient.DeleteRunAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await lineageClient.PollOnceDeleteRunAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
GetLineageEventRequest request = new GetLineageEventRequest
{
    LineageEventName = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]"),
};
// Make the request
LineageEvent response = lineageClient.GetLineageEvent(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
LineageEventName name = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
// Make the request
LineageEvent response = lineageClient.GetLineageEvent(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]/lineageEvents/[LINEAGE_EVENT]";
// Make the request
LineageEvent response = lineageClient.GetLineageEvent(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
GetLineageEventRequest request = new GetLineageEventRequest
{
    LineageEventName = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]"),
};
// Make the request
LineageEvent response = await lineageClient.GetLineageEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
GetLineageEventRequest request = new GetLineageEventRequest
{
    LineageEventName = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]"),
};
// Make the request
LineageEvent response = await lineageClient.GetLineageEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LineageEventName name = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
// Make the request
LineageEvent response = await lineageClient.GetLineageEventAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LineageEventName name = LineageEventName.FromProjectLocationProcessRunLineageEvent("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
// Make the request
LineageEvent response = await lineageClient.GetLineageEventAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]/lineageEvents/[LINEAGE_EVENT]";
// Make the request
LineageEvent response = await lineageClient.GetLineageEventAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]/lineageEvents/[LINEAGE_EVENT]";
// Make the request
LineageEvent response = await lineageClient.GetLineageEventAsync(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
GetProcessRequest request = new GetProcessRequest
{
    ProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
};
// Make the request
Process response = lineageClient.GetProcess(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ProcessName name = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
Process response = lineageClient.GetProcess(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
Process response = lineageClient.GetProcess(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
GetProcessRequest request = new GetProcessRequest
{
    ProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
};
// Make the request
Process response = await lineageClient.GetProcessAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
GetProcessRequest request = new GetProcessRequest
{
    ProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
};
// Make the request
Process response = await lineageClient.GetProcessAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName name = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
Process response = await lineageClient.GetProcessAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName name = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
Process response = await lineageClient.GetProcessAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
Process response = await lineageClient.GetProcessAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
Process response = await lineageClient.GetProcessAsync(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
GetRunRequest request = new GetRunRequest
{
    RunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
};
// Make the request
Run response = lineageClient.GetRun(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
RunName name = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
Run response = lineageClient.GetRun(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
Run response = lineageClient.GetRun(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
GetRunRequest request = new GetRunRequest
{
    RunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
};
// Make the request
Run response = await lineageClient.GetRunAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
GetRunRequest request = new GetRunRequest
{
    RunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
};
// Make the request
Run response = await lineageClient.GetRunAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName name = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
Run response = await lineageClient.GetRunAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName name = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
Run response = await lineageClient.GetRunAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
Run response = await lineageClient.GetRunAsync(name);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
Run response = await lineageClient.GetRunAsync(name);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ListLineageEventsRequest request = new ListLineageEventsRequest
{
    ParentAsRunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
};
// Make the request
PagedEnumerable<ListLineageEventsResponse, LineageEvent> response = lineageClient.ListLineageEvents(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (LineageEvent item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListLineageEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (LineageEvent item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<LineageEvent> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (LineageEvent item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
RunName parent = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
PagedEnumerable<ListLineageEventsResponse, LineageEvent> response = lineageClient.ListLineageEvents(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (LineageEvent item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListLineageEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (LineageEvent item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<LineageEvent> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (LineageEvent item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
PagedEnumerable<ListLineageEventsResponse, LineageEvent> response = lineageClient.ListLineageEvents(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (LineageEvent item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListLineageEventsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (LineageEvent item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<LineageEvent> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (LineageEvent item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ListLineageEventsRequest request = new ListLineageEventsRequest
{
    ParentAsRunName = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]"),
};
// Make the request
PagedAsyncEnumerable<ListLineageEventsResponse, LineageEvent> response = lineageClient.ListLineageEventsAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((LineageEvent item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListLineageEventsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (LineageEvent item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<LineageEvent> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (LineageEvent item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
RunName parent = RunName.FromProjectLocationProcessRun("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
// Make the request
PagedAsyncEnumerable<ListLineageEventsResponse, LineageEvent> response = lineageClient.ListLineageEventsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((LineageEvent item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListLineageEventsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (LineageEvent item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<LineageEvent> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (LineageEvent item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]/runs/[RUN]";
// Make the request
PagedAsyncEnumerable<ListLineageEventsResponse, LineageEvent> response = lineageClient.ListLineageEventsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((LineageEvent item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListLineageEventsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (LineageEvent item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<LineageEvent> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (LineageEvent item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<ListProcessesResponse, Process> response = lineageClient.ListProcesses(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Process item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListProcessesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Process item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Process> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Process item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ListProcessesRequest request = new ListProcessesRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
};
// Make the request
PagedEnumerable<ListProcessesResponse, Process> response = lineageClient.ListProcesses(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Process item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListProcessesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Process item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Process> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Process item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<ListProcessesResponse, Process> response = lineageClient.ListProcesses(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Process item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListProcessesResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Process item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Process> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Process item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<ListProcessesResponse, Process> response = lineageClient.ListProcessesAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Process item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListProcessesResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Process item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Process> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Process item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ListProcessesRequest request = new ListProcessesRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
};
// Make the request
PagedAsyncEnumerable<ListProcessesResponse, Process> response = lineageClient.ListProcessesAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Process item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListProcessesResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Process item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Process> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Process item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<ListProcessesResponse, Process> response = lineageClient.ListProcessesAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Process item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListProcessesResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Process item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Process> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Process item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ListRunsRequest request = new ListRunsRequest
{
    ParentAsProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
};
// Make the request
PagedEnumerable<ListRunsResponse, Run> response = lineageClient.ListRuns(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Run item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListRunsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Run item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Run> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Run item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ProcessName parent = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
PagedEnumerable<ListRunsResponse, Run> response = lineageClient.ListRuns(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Run item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListRunsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Run item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Run> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Run item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
PagedEnumerable<ListRunsResponse, Run> response = lineageClient.ListRuns(parent);

// Iterate over all response items, lazily performing RPCs as required
foreach (Run item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (ListRunsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Run item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Run> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Run item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ListRunsRequest request = new ListRunsRequest
{
    ParentAsProcessName = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]"),
};
// Make the request
PagedAsyncEnumerable<ListRunsResponse, Run> response = lineageClient.ListRunsAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Run item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListRunsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Run item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Run> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Run item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessName parent = ProcessName.FromProjectLocationProcess("[PROJECT]", "[LOCATION]", "[PROCESS]");
// Make the request
PagedAsyncEnumerable<ListRunsResponse, Run> response = lineageClient.ListRunsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Run item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListRunsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Run item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Run> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Run item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/processes/[PROCESS]";
// Make the request
PagedAsyncEnumerable<ListRunsResponse, Run> response = lineageClient.ListRunsAsync(parent);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Run item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((ListRunsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Run item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Run> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Run item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
ProcessOpenLineageRunEventRequest request = new ProcessOpenLineageRunEventRequest
{
    Parent = "",
    OpenLineage = new Struct(),
    RequestId = "",
};
// Make the request
ProcessOpenLineageRunEventResponse response = lineageClient.ProcessOpenLineageRunEvent(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
string parent = "";
Struct openLineage = new Struct();
// Make the request
ProcessOpenLineageRunEventResponse response = lineageClient.ProcessOpenLineageRunEvent(parent, openLineage);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessOpenLineageRunEventRequest request = new ProcessOpenLineageRunEventRequest
{
    Parent = "",
    OpenLineage = new Struct(),
    RequestId = "",
};
// Make the request
ProcessOpenLineageRunEventResponse response = await lineageClient.ProcessOpenLineageRunEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
ProcessOpenLineageRunEventRequest request = new ProcessOpenLineageRunEventRequest
{
    Parent = "",
    OpenLineage = new Struct(),
    RequestId = "",
};
// Make the request
ProcessOpenLineageRunEventResponse response = await lineageClient.ProcessOpenLineageRunEventAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "";
Struct openLineage = new Struct();
// Make the request
ProcessOpenLineageRunEventResponse response = await lineageClient.ProcessOpenLineageRunEventAsync(parent, openLineage);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
string parent = "";
Struct openLineage = new Struct();
// Make the request
ProcessOpenLineageRunEventResponse response = await lineageClient.ProcessOpenLineageRunEventAsync(parent, openLineage);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
SearchLinksRequest request = new SearchLinksRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Source = new EntityReference(),
};
// Make the request
PagedEnumerable<SearchLinksResponse, Link> response = lineageClient.SearchLinks(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (Link item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (SearchLinksResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Link item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Link> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Link item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
SearchLinksRequest request = new SearchLinksRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    Source = new EntityReference(),
};
// Make the request
PagedAsyncEnumerable<SearchLinksResponse, Link> response = lineageClient.SearchLinksAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((Link item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((SearchLinksResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (Link item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<Link> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (Link item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
Process process = new Process();
FieldMask updateMask = new FieldMask();
// Make the request
Process response = lineageClient.UpdateProcess(process, updateMask);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
UpdateProcessRequest request = new UpdateProcessRequest
{
    Process = new Process(),
    UpdateMask = new FieldMask(),
    AllowMissing = false,
};
// Make the request
Process response = lineageClient.UpdateProcess(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
Process process = new Process();
FieldMask updateMask = new FieldMask();
// Make the request
Process response = await lineageClient.UpdateProcessAsync(process, updateMask);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
Process process = new Process();
FieldMask updateMask = new FieldMask();
// Make the request
Process response = await lineageClient.UpdateProcessAsync(process, updateMask);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
UpdateProcessRequest request = new UpdateProcessRequest
{
    Process = new Process(),
    UpdateMask = new FieldMask(),
    AllowMissing = false,
};
// Make the request
Process response = await lineageClient.UpdateProcessAsync(request);

// Create client
LineageClient lineageClient = await LineageClient.CreateAsync();
// Initialize request argument(s)
UpdateProcessRequest request = new UpdateProcessRequest
{
    Process = new Process(),
    UpdateMask = new FieldMask(),
    AllowMissing = false,
};
// Make the request
Process response = await lineageClient.UpdateProcessAsync(request);

// Create client
LineageClient lineageClient = LineageClient.Create();
// Initialize request argument(s)
Run run = new Run();
FieldMask updateMask = new FieldMask();
// Make the request
Run response = lineageClient.UpdateRun(run, updateMask);