Skip to content

Commit

Permalink
feat: add UNAVAILABLE to state enum of workflow deployment
Browse files Browse the repository at this point in the history
feat: add state_error field to Workflow
feat: add call_log_level field to Workflow
feat: add user_env_vars field to Workflow
feat: add revision_id to GetWorkflowRequest

PiperOrigin-RevId: 556898168

Source-Link: googleapis/googleapis@964e82f

Source-Link: googleapis/googleapis-gen@de97a5d
Copy-Tag: eyJwIjoiYXBpcy9Hb29nbGUuQ2xvdWQuV29ya2Zsb3dzLlYxLy5Pd2xCb3QueWFtbCIsImgiOiJkZTk3YTVkNjBmNzY5MTIxY2YzMDg3Yzk4NmIyNzhlOTRiZGQ5NDNkIn0=
  • Loading branch information
gcf-owl-bot[bot] authored and jskeet committed Aug 15, 2023
1 parent 1b3e23f commit a3003fc
Show file tree
Hide file tree
Showing 10 changed files with 1,007 additions and 167 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ public async Task GetWorkflowRequestObjectAsync()
GetWorkflowRequest request = new GetWorkflowRequest
{
WorkflowName = WorkflowName.FromProjectLocationWorkflow("[PROJECT]", "[LOCATION]", "[WORKFLOW]"),
RevisionId = "",
};
// Make the request
Workflow response = await workflowsClient.GetWorkflowAsync(request);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ public void GetWorkflowRequestObject()
GetWorkflowRequest request = new GetWorkflowRequest
{
WorkflowName = WorkflowName.FromProjectLocationWorkflow("[PROJECT]", "[LOCATION]", "[WORKFLOW]"),
RevisionId = "",
};
// Make the request
Workflow response = workflowsClient.GetWorkflow(request);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -367,12 +367,12 @@
"segments": [
{
"start": 20,
"end": 45,
"end": 46,
"type": "FULL"
},
{
"start": 35,
"end": 43,
"end": 44,
"type": "SHORT"
}
]
Expand Down Expand Up @@ -416,12 +416,12 @@
"segments": [
{
"start": 20,
"end": 46,
"end": 47,
"type": "FULL"
},
{
"start": 36,
"end": 44,
"end": 45,
"type": "SHORT"
}
]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -319,6 +319,7 @@ public void GetWorkflowRequestObject()
GetWorkflowRequest request = new GetWorkflowRequest
{
WorkflowName = WorkflowName.FromProjectLocationWorkflow("[PROJECT]", "[LOCATION]", "[WORKFLOW]"),
RevisionId = "",
};
// Make the request
Workflow response = workflowsClient.GetWorkflow(request);
Expand All @@ -336,6 +337,7 @@ public async Task GetWorkflowRequestObjectAsync()
GetWorkflowRequest request = new GetWorkflowRequest
{
WorkflowName = WorkflowName.FromProjectLocationWorkflow("[PROJECT]", "[LOCATION]", "[WORKFLOW]"),
RevisionId = "",
};
// Make the request
Workflow response = await workflowsClient.GetWorkflowAsync(request);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@

#pragma warning disable CS8981
using gaxgrpc = Google.Api.Gax.Grpc;
using gcl = Google.Cloud.Location;
using lro = Google.LongRunning;
using proto = Google.Protobuf;
using gpr = Google.Protobuf.Reflection;
Expand All @@ -31,6 +32,16 @@ internal static class PackageApiMetadata
.WithRequestNumericEnumJsonEncoding(true)
.WithHttpRuleOverrides(new scg::Dictionary<string, proto::ByteString>
{
{
"google.cloud.location.Locations.GetLocation",
// { "get": "/v1/{name=projects/*/locations/*}" }
proto::ByteString.FromBase64("EiEvdjEve25hbWU9cHJvamVjdHMvKi9sb2NhdGlvbnMvKn0=")
},
{
"google.cloud.location.Locations.ListLocations",
// { "get": "/v1/{name=projects/*}/locations" }
proto::ByteString.FromBase64("Eh8vdjEve25hbWU9cHJvamVjdHMvKn0vbG9jYXRpb25z")
},
{
"google.longrunning.Operations.DeleteOperation",
// { "delete": "/v1/{name=projects/*/locations/*/operations/*}" }
Expand All @@ -50,6 +61,7 @@ internal static class PackageApiMetadata

private static scg::IEnumerable<gpr::FileDescriptor> GetFileDescriptors()
{
yield return gcl::LocationsReflection.Descriptor;
yield return WorkflowsReflection.Descriptor;
yield return lro::OperationsReflection.Descriptor;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@

#pragma warning disable CS8981
using gaxgrpc = Google.Api.Gax.Grpc;
using gcl = Google.Cloud.Location;
using gcwv = Google.Cloud.Workflows.V1;
using lro = Google.LongRunning;
using proto = Google.Protobuf;
Expand Down
694 changes: 609 additions & 85 deletions apis/Google.Cloud.Workflows.V1/Google.Cloud.Workflows.V1/Workflows.g.cs

Large diffs are not rendered by default.

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
// source: google/cloud/workflows/v1/workflows.proto
// </auto-generated>
// Original file comments:
// Copyright 2021 Google LLC
// Copyright 2023 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -133,7 +133,7 @@ static class __Helper_MessageCache<T>
public abstract partial class WorkflowsBase
{
/// <summary>
/// Lists Workflows in a given project and location.
/// Lists workflows in a given project and location.
/// The default order is not specified.
/// </summary>
/// <param name="request">The request received from the client.</param>
Expand All @@ -146,7 +146,7 @@ public abstract partial class WorkflowsBase
}

/// <summary>
/// Gets details of a single Workflow.
/// Gets details of a single workflow.
/// </summary>
/// <param name="request">The request received from the client.</param>
/// <param name="context">The context of the server-side call handler being invoked.</param>
Expand All @@ -160,7 +160,7 @@ public abstract partial class WorkflowsBase
/// <summary>
/// Creates a new workflow. If a workflow with the specified name already
/// exists in the specified project and location, the long running operation
/// will return [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// </summary>
/// <param name="request">The request received from the client.</param>
/// <param name="context">The context of the server-side call handler being invoked.</param>
Expand Down Expand Up @@ -188,8 +188,8 @@ public abstract partial class WorkflowsBase
/// <summary>
/// Updates an existing workflow.
/// Running this method has no impact on already running executions of the
/// workflow. A new revision of the workflow may be created as a result of a
/// successful update operation. In that case, such revision will be used
/// workflow. A new revision of the workflow might be created as a result of a
/// successful update operation. In that case, the new revision is used
/// in new workflow executions.
/// </summary>
/// <param name="request">The request received from the client.</param>
Expand Down Expand Up @@ -231,7 +231,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
}

/// <summary>
/// Lists Workflows in a given project and location.
/// Lists workflows in a given project and location.
/// The default order is not specified.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -245,7 +245,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return ListWorkflows(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
/// <summary>
/// Lists Workflows in a given project and location.
/// Lists workflows in a given project and location.
/// The default order is not specified.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -257,7 +257,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return CallInvoker.BlockingUnaryCall(__Method_ListWorkflows, null, options, request);
}
/// <summary>
/// Lists Workflows in a given project and location.
/// Lists workflows in a given project and location.
/// The default order is not specified.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -271,7 +271,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return ListWorkflowsAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
/// <summary>
/// Lists Workflows in a given project and location.
/// Lists workflows in a given project and location.
/// The default order is not specified.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -283,7 +283,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return CallInvoker.AsyncUnaryCall(__Method_ListWorkflows, null, options, request);
}
/// <summary>
/// Gets details of a single Workflow.
/// Gets details of a single workflow.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
Expand All @@ -296,7 +296,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return GetWorkflow(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
/// <summary>
/// Gets details of a single Workflow.
/// Gets details of a single workflow.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="options">The options for the call.</param>
Expand All @@ -307,7 +307,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return CallInvoker.BlockingUnaryCall(__Method_GetWorkflow, null, options, request);
}
/// <summary>
/// Gets details of a single Workflow.
/// Gets details of a single workflow.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
Expand All @@ -320,7 +320,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
return GetWorkflowAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
/// <summary>
/// Gets details of a single Workflow.
/// Gets details of a single workflow.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="options">The options for the call.</param>
Expand All @@ -333,7 +333,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Creates a new workflow. If a workflow with the specified name already
/// exists in the specified project and location, the long running operation
/// will return [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
Expand All @@ -348,7 +348,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Creates a new workflow. If a workflow with the specified name already
/// exists in the specified project and location, the long running operation
/// will return [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="options">The options for the call.</param>
Expand All @@ -361,7 +361,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Creates a new workflow. If a workflow with the specified name already
/// exists in the specified project and location, the long running operation
/// will return [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
Expand All @@ -376,7 +376,7 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Creates a new workflow. If a workflow with the specified name already
/// exists in the specified project and location, the long running operation
/// will return [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
/// </summary>
/// <param name="request">The request to send to the server.</param>
/// <param name="options">The options for the call.</param>
Expand Down Expand Up @@ -445,8 +445,8 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Updates an existing workflow.
/// Running this method has no impact on already running executions of the
/// workflow. A new revision of the workflow may be created as a result of a
/// successful update operation. In that case, such revision will be used
/// workflow. A new revision of the workflow might be created as a result of a
/// successful update operation. In that case, the new revision is used
/// in new workflow executions.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -462,8 +462,8 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Updates an existing workflow.
/// Running this method has no impact on already running executions of the
/// workflow. A new revision of the workflow may be created as a result of a
/// successful update operation. In that case, such revision will be used
/// workflow. A new revision of the workflow might be created as a result of a
/// successful update operation. In that case, the new revision is used
/// in new workflow executions.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -477,8 +477,8 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Updates an existing workflow.
/// Running this method has no impact on already running executions of the
/// workflow. A new revision of the workflow may be created as a result of a
/// successful update operation. In that case, such revision will be used
/// workflow. A new revision of the workflow might be created as a result of a
/// successful update operation. In that case, the new revision is used
/// in new workflow executions.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand All @@ -494,8 +494,8 @@ protected WorkflowsClient(ClientBaseConfiguration configuration) : base(configur
/// <summary>
/// Updates an existing workflow.
/// Running this method has no impact on already running executions of the
/// workflow. A new revision of the workflow may be created as a result of a
/// successful update operation. In that case, such revision will be used
/// workflow. A new revision of the workflow might be created as a result of a
/// successful update operation. In that case, the new revision is used
/// in new workflow executions.
/// </summary>
/// <param name="request">The request to send to the server.</param>
Expand Down

0 comments on commit a3003fc

Please sign in to comment.