Skip to content

Commit

Permalink
Concept hooks return ExecutionStatusResponse (#207)
Browse files Browse the repository at this point in the history
Signed-off-by: Piotr Nestorow <[email protected]>
  • Loading branch information
PiotrNestor authored Feb 24, 2024
1 parent 5a9f766 commit 057eb67
Show file tree
Hide file tree
Showing 7 changed files with 221 additions and 263 deletions.
4 changes: 2 additions & 2 deletions src/ExecutableRunnerServiceHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -115,12 +115,12 @@ public override Task<ExecutionStatusResponse> StartStepExecution(StepExecutionSt
return _pool.Execute(getStream(request.Stream), () => this.stepExecutionStartingProcessor.Process(request));
}

public override Task<Empty> NotifyConceptExecutionStarting(ConceptExecutionStartingRequest request, ServerCallContext context)
public override Task<ExecutionStatusResponse> NotifyConceptExecutionStarting(ConceptExecutionStartingRequest request, ServerCallContext context)
{
return _pool.Execute(getStream(request.Stream), () => this.conceptExecutionStartingProcessor.Process(request));
}

public override Task<Empty> NotifyConceptExecutionEnding(ConceptExecutionEndingRequest request, ServerCallContext context)
public override Task<ExecutionStatusResponse> NotifyConceptExecutionEnding(ConceptExecutionEndingRequest request, ServerCallContext context)
{
return _pool.Execute(getStream(request.Stream), () => this.conceptExecutionEndingProcessor.Process(request));
}
Expand Down
342 changes: 151 additions & 191 deletions src/Gauge.CSharp.Core/Messages.cs

Large diffs are not rendered by default.

74 changes: 37 additions & 37 deletions src/Gauge.CSharp.Core/Services.cs
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ static ServicesReflection() {
byte[] descriptorData = global::System.Convert.FromBase64String(
string.Concat(
"Cg5zZXJ2aWNlcy5wcm90bxIOZ2F1Z2UubWVzc2FnZXMaDm1lc3NhZ2VzLnBy",
"b3RvMsMSCgZSdW5uZXISWQoMVmFsaWRhdGVTdGVwEiMuZ2F1Z2UubWVzc2Fn",
"b3RvMucSCgZSdW5uZXISWQoMVmFsaWRhdGVTdGVwEiMuZ2F1Z2UubWVzc2Fn",
"ZXMuU3RlcFZhbGlkYXRlUmVxdWVzdBokLmdhdWdlLm1lc3NhZ2VzLlN0ZXBW",
"YWxpZGF0ZVJlc3BvbnNlEm4KGEluaXRpYWxpemVTdWl0ZURhdGFTdG9yZRIp",
"LmdhdWdlLm1lc3NhZ2VzLlN1aXRlRGF0YVN0b3JlSW5pdFJlcXVlc3QaJy5n",
Expand Down Expand Up @@ -73,43 +73,43 @@ static ServicesReflection() {
"CghSZWZhY3RvchIfLmdhdWdlLm1lc3NhZ2VzLlJlZmFjdG9yUmVxdWVzdBog",
"LmdhdWdlLm1lc3NhZ2VzLlJlZmFjdG9yUmVzcG9uc2USQQoES2lsbBIiLmdh",
"dWdlLm1lc3NhZ2VzLktpbGxQcm9jZXNzUmVxdWVzdBoVLmdhdWdlLm1lc3Nh",
"Z2VzLkVtcHR5EmgKHk5vdGlmeUNvbmNlcHRFeGVjdXRpb25TdGFydGluZxIv",
"Z2VzLkVtcHR5EnoKHk5vdGlmeUNvbmNlcHRFeGVjdXRpb25TdGFydGluZxIv",
"LmdhdWdlLm1lc3NhZ2VzLkNvbmNlcHRFeGVjdXRpb25TdGFydGluZ1JlcXVl",
"c3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eRJkChxOb3RpZnlDb25jZXB0RXhl",
"Y3V0aW9uRW5kaW5nEi0uZ2F1Z2UubWVzc2FnZXMuQ29uY2VwdEV4ZWN1dGlv",
"bkVuZGluZ1JlcXVlc3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eTL/CAoIUmVw",
"b3J0ZXISWgoXTm90aWZ5RXhlY3V0aW9uU3RhcnRpbmcSKC5nYXVnZS5tZXNz",
"YWdlcy5FeGVjdXRpb25TdGFydGluZ1JlcXVlc3QaFS5nYXVnZS5tZXNzYWdl",
"cy5FbXB0eRJiChtOb3RpZnlTcGVjRXhlY3V0aW9uU3RhcnRpbmcSLC5nYXVn",
"ZS5tZXNzYWdlcy5TcGVjRXhlY3V0aW9uU3RhcnRpbmdSZXF1ZXN0GhUuZ2F1",
"Z2UubWVzc2FnZXMuRW1wdHkSagofTm90aWZ5U2NlbmFyaW9FeGVjdXRpb25T",
"dGFydGluZxIwLmdhdWdlLm1lc3NhZ2VzLlNjZW5hcmlvRXhlY3V0aW9uU3Rh",
"cnRpbmdSZXF1ZXN0GhUuZ2F1Z2UubWVzc2FnZXMuRW1wdHkSaAoeTm90aWZ5",
"Q29uY2VwdEV4ZWN1dGlvblN0YXJ0aW5nEi8uZ2F1Z2UubWVzc2FnZXMuQ29u",
"Y2VwdEV4ZWN1dGlvblN0YXJ0aW5nUmVxdWVzdBoVLmdhdWdlLm1lc3NhZ2Vz",
"LkVtcHR5EmQKHE5vdGlmeUNvbmNlcHRFeGVjdXRpb25FbmRpbmcSLS5nYXVn",
"ZS5tZXNzYWdlcy5Db25jZXB0RXhlY3V0aW9uRW5kaW5nUmVxdWVzdBoVLmdh",
"dWdlLm1lc3NhZ2VzLkVtcHR5EmIKG05vdGlmeVN0ZXBFeGVjdXRpb25TdGFy",
"dGluZxIsLmdhdWdlLm1lc3NhZ2VzLlN0ZXBFeGVjdXRpb25TdGFydGluZ1Jl",
"cXVlc3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eRJeChlOb3RpZnlTdGVwRXhl",
"Y3V0aW9uRW5kaW5nEiouZ2F1Z2UubWVzc2FnZXMuU3RlcEV4ZWN1dGlvbkVu",
"ZGluZ1JlcXVlc3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eRJmCh1Ob3RpZnlT",
"Y2VuYXJpb0V4ZWN1dGlvbkVuZGluZxIuLmdhdWdlLm1lc3NhZ2VzLlNjZW5h",
"cmlvRXhlY3V0aW9uRW5kaW5nUmVxdWVzdBoVLmdhdWdlLm1lc3NhZ2VzLkVt",
"cHR5El4KGU5vdGlmeVNwZWNFeGVjdXRpb25FbmRpbmcSKi5nYXVnZS5tZXNz",
"YWdlcy5TcGVjRXhlY3V0aW9uRW5kaW5nUmVxdWVzdBoVLmdhdWdlLm1lc3Nh",
"Z2VzLkVtcHR5ElYKFU5vdGlmeUV4ZWN1dGlvbkVuZGluZxImLmdhdWdlLm1l",
"c3NhZ2VzLkV4ZWN1dGlvbkVuZGluZ1JlcXVlc3QaFS5nYXVnZS5tZXNzYWdl",
"cy5FbXB0eRJQChFOb3RpZnlTdWl0ZVJlc3VsdBIkLmdhdWdlLm1lc3NhZ2Vz",
"LlN1aXRlRXhlY3V0aW9uUmVzdWx0GhUuZ2F1Z2UubWVzc2FnZXMuRW1wdHkS",
"QQoES2lsbBIiLmdhdWdlLm1lc3NhZ2VzLktpbGxQcm9jZXNzUmVxdWVzdBoV",
"LmdhdWdlLm1lc3NhZ2VzLkVtcHR5MpMBCgpEb2N1bWVudGVyEkIKDEdlbmVy",
"YXRlRG9jcxIbLmdhdWdlLm1lc3NhZ2VzLlNwZWNEZXRhaWxzGhUuZ2F1Z2Uu",
"bWVzc2FnZXMuRW1wdHkSQQoES2lsbBIiLmdhdWdlLm1lc3NhZ2VzLktpbGxQ",
"cm9jZXNzUmVxdWVzdBoVLmdhdWdlLm1lc3NhZ2VzLkVtcHR5QlwKFmNvbS50",
"aG91Z2h0d29ya3MuZ2F1Z2VaMWdpdGh1Yi5jb20vZ2V0Z2F1Z2UvZ2F1Z2Ut",
"cHJvdG8vZ28vZ2F1Z2VfbWVzc2FnZXOqAg5HYXVnZS5NZXNzYWdlc2IGcHJv",
"dG8z"));
"c3QaJy5nYXVnZS5tZXNzYWdlcy5FeGVjdXRpb25TdGF0dXNSZXNwb25zZRJ2",
"ChxOb3RpZnlDb25jZXB0RXhlY3V0aW9uRW5kaW5nEi0uZ2F1Z2UubWVzc2Fn",
"ZXMuQ29uY2VwdEV4ZWN1dGlvbkVuZGluZ1JlcXVlc3QaJy5nYXVnZS5tZXNz",
"YWdlcy5FeGVjdXRpb25TdGF0dXNSZXNwb25zZTL/CAoIUmVwb3J0ZXISWgoX",
"Tm90aWZ5RXhlY3V0aW9uU3RhcnRpbmcSKC5nYXVnZS5tZXNzYWdlcy5FeGVj",
"dXRpb25TdGFydGluZ1JlcXVlc3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eRJi",
"ChtOb3RpZnlTcGVjRXhlY3V0aW9uU3RhcnRpbmcSLC5nYXVnZS5tZXNzYWdl",
"cy5TcGVjRXhlY3V0aW9uU3RhcnRpbmdSZXF1ZXN0GhUuZ2F1Z2UubWVzc2Fn",
"ZXMuRW1wdHkSagofTm90aWZ5U2NlbmFyaW9FeGVjdXRpb25TdGFydGluZxIw",
"LmdhdWdlLm1lc3NhZ2VzLlNjZW5hcmlvRXhlY3V0aW9uU3RhcnRpbmdSZXF1",
"ZXN0GhUuZ2F1Z2UubWVzc2FnZXMuRW1wdHkSaAoeTm90aWZ5Q29uY2VwdEV4",
"ZWN1dGlvblN0YXJ0aW5nEi8uZ2F1Z2UubWVzc2FnZXMuQ29uY2VwdEV4ZWN1",
"dGlvblN0YXJ0aW5nUmVxdWVzdBoVLmdhdWdlLm1lc3NhZ2VzLkVtcHR5EmQK",
"HE5vdGlmeUNvbmNlcHRFeGVjdXRpb25FbmRpbmcSLS5nYXVnZS5tZXNzYWdl",
"cy5Db25jZXB0RXhlY3V0aW9uRW5kaW5nUmVxdWVzdBoVLmdhdWdlLm1lc3Nh",
"Z2VzLkVtcHR5EmIKG05vdGlmeVN0ZXBFeGVjdXRpb25TdGFydGluZxIsLmdh",
"dWdlLm1lc3NhZ2VzLlN0ZXBFeGVjdXRpb25TdGFydGluZ1JlcXVlc3QaFS5n",
"YXVnZS5tZXNzYWdlcy5FbXB0eRJeChlOb3RpZnlTdGVwRXhlY3V0aW9uRW5k",
"aW5nEiouZ2F1Z2UubWVzc2FnZXMuU3RlcEV4ZWN1dGlvbkVuZGluZ1JlcXVl",
"c3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eRJmCh1Ob3RpZnlTY2VuYXJpb0V4",
"ZWN1dGlvbkVuZGluZxIuLmdhdWdlLm1lc3NhZ2VzLlNjZW5hcmlvRXhlY3V0",
"aW9uRW5kaW5nUmVxdWVzdBoVLmdhdWdlLm1lc3NhZ2VzLkVtcHR5El4KGU5v",
"dGlmeVNwZWNFeGVjdXRpb25FbmRpbmcSKi5nYXVnZS5tZXNzYWdlcy5TcGVj",
"RXhlY3V0aW9uRW5kaW5nUmVxdWVzdBoVLmdhdWdlLm1lc3NhZ2VzLkVtcHR5",
"ElYKFU5vdGlmeUV4ZWN1dGlvbkVuZGluZxImLmdhdWdlLm1lc3NhZ2VzLkV4",
"ZWN1dGlvbkVuZGluZ1JlcXVlc3QaFS5nYXVnZS5tZXNzYWdlcy5FbXB0eRJQ",
"ChFOb3RpZnlTdWl0ZVJlc3VsdBIkLmdhdWdlLm1lc3NhZ2VzLlN1aXRlRXhl",
"Y3V0aW9uUmVzdWx0GhUuZ2F1Z2UubWVzc2FnZXMuRW1wdHkSQQoES2lsbBIi",
"LmdhdWdlLm1lc3NhZ2VzLktpbGxQcm9jZXNzUmVxdWVzdBoVLmdhdWdlLm1l",
"c3NhZ2VzLkVtcHR5MpMBCgpEb2N1bWVudGVyEkIKDEdlbmVyYXRlRG9jcxIb",
"LmdhdWdlLm1lc3NhZ2VzLlNwZWNEZXRhaWxzGhUuZ2F1Z2UubWVzc2FnZXMu",
"RW1wdHkSQQoES2lsbBIiLmdhdWdlLm1lc3NhZ2VzLktpbGxQcm9jZXNzUmVx",
"dWVzdBoVLmdhdWdlLm1lc3NhZ2VzLkVtcHR5QlwKFmNvbS50aG91Z2h0d29y",
"a3MuZ2F1Z2VaMWdpdGh1Yi5jb20vZ2V0Z2F1Z2UvZ2F1Z2UtcHJvdG8vZ28v",
"Z2F1Z2VfbWVzc2FnZXOqAg5HYXVnZS5NZXNzYWdlc2IGcHJvdG8z"));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { global::Gauge.Messages.MessagesReflection.Descriptor, },
new pbr::GeneratedClrTypeInfo(null, null, null));
Expand Down
Loading

0 comments on commit 057eb67

Please sign in to comment.