15 writes to Data
aspire (1)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (1)
32
ObjectWithParameterizedConstructorCreator = static args => new global::Aspire.Cli.Backchannel.PublishingActivity(){ Type = (string)args[0],
Data
= (global::Aspire.Cli.Backchannel.PublishingActivityData)args[1] },
Aspire.Cli.Tests (14)
Commands\DeployCommandTests.cs (5)
408
Data
= new PublishingActivityData
421
Data
= new PublishingActivityData
433
Data
= new PublishingActivityData
447
Data
= new PublishingActivityData
460
Data
= new PublishingActivityData
Commands\PublishCommandPromptingIntegrationTests.cs (1)
770
Data
= new PublishingActivityData
TestServices\TestAppHostCliBackchannel.cs (8)
125
Data
= new PublishingActivityData
136
Data
= new PublishingActivityData
147
Data
= new PublishingActivityData
158
Data
= new PublishingActivityData
169
Data
= new PublishingActivityData
180
Data
= new PublishingActivityData
191
Data
= new PublishingActivityData
202
Data
= new PublishingActivityData
75 references to Data
aspire (75)
BackchannelJsonSerializerContext.PublishingActivity.g.cs (2)
81
Getter = static obj => ((global::Aspire.Cli.Backchannel.PublishingActivity)obj).
Data
,
114
PublishingActivityDataSerializeHandler(writer, ((global::Aspire.Cli.Backchannel.PublishingActivity)value).
Data
);
Commands\PipelineCommandBase.cs (73)
329
if (!steps.TryGetValue(activity.
Data
.Id, out var stepStatus))
332
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
334
steps[activity.
Data
.Id] = activity.
Data
.CompletionState;
336
else if (IsCompletionStateComplete(activity.
Data
.CompletionState))
339
var status = IsCompletionStateError(activity.
Data
.CompletionState) ? "FAILED" :
340
IsCompletionStateWarning(activity.
Data
.CompletionState) ? "WARNING" : "COMPLETED";
341
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
342
InteractionService.DisplaySubtleMessage($"[[DEBUG]] Step {activity.
Data
.Id}: {status} - {statusText}", escapeMarkup: false);
343
steps[activity.
Data
.Id] = activity.
Data
.CompletionState;
353
var logLevel = activity.
Data
.LogLevel ?? "Information";
354
var message = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
355
var timestamp = activity.
Data
.Timestamp?.ToString("HH:mm:ss", CultureInfo.InvariantCulture) ?? DateTimeOffset.UtcNow.ToString("HH:mm:ss", CultureInfo.InvariantCulture);
382
var stepId = activity.
Data
.StepId;
383
if (IsCompletionStateComplete(activity.
Data
.CompletionState))
385
var status = IsCompletionStateError(activity.
Data
.CompletionState) ? "FAILED" :
386
IsCompletionStateWarning(activity.
Data
.CompletionState) ? "WARNING" : "COMPLETED";
387
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
388
InteractionService.DisplaySubtleMessage($"[[DEBUG]] Task {activity.
Data
.Id} ({stepId}): {status} - {statusText}", escapeMarkup: false);
389
if (!string.IsNullOrEmpty(activity.
Data
.CompletionMessage))
391
var completionMessage = ConvertTextWithMarkdownFlag(activity.
Data
.CompletionMessage, activity.
Data
);
397
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
398
InteractionService.DisplaySubtleMessage($"[[DEBUG]] Task {activity.
Data
.Id} ({stepId}): {statusText}", escapeMarkup: false);
403
var hasErrors = publishingActivity is not null && IsCompletionStateError(publishingActivity.
Data
.CompletionState);
404
var hasWarnings = publishingActivity is not null && IsCompletionStateWarning(publishingActivity.
Data
.CompletionState);
409
var statusText = ConvertTextWithMarkdownFlag(publishingActivity.
Data
.StatusText, publishingActivity.
Data
);
440
if (!steps.TryGetValue(activity.
Data
.Id, out var stepInfo))
442
var title = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
445
Id = activity.
Data
.Id,
449
CompletionState = activity.
Data
.CompletionState
452
steps[activity.
Data
.Id] = stepInfo;
456
else if (IsCompletionStateComplete(activity.
Data
.CompletionState))
458
stepInfo.CompletionState = activity.
Data
.CompletionState;
459
stepInfo.CompletionText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
484
var stepId = activity.
Data
.StepId;
487
var logLevel = activity.
Data
.LogLevel ?? "Information";
488
var message = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
531
var stepId = activity.
Data
.StepId;
536
throw new InvalidOperationException($"Step '{stepId}' not found for task '{activity.
Data
.Id}'");
541
if (!tasks.TryGetValue(activity.
Data
.Id, out var task))
543
var statusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
546
Id = activity.
Data
.Id,
549
CompletionState = activity.
Data
.CompletionState
552
tasks[activity.
Data
.Id] = task;
556
task.StatusText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
557
task.CompletionState = activity.
Data
.CompletionState;
559
if (IsCompletionStateComplete(activity.
Data
.CompletionState))
561
task.CompletionMessage = !string.IsNullOrEmpty(activity.
Data
.CompletionMessage)
562
? ConvertTextWithMarkdownFlag(activity.
Data
.CompletionMessage, activity.
Data
)
596
var hasErrors = IsCompletionStateError(publishingActivity.
Data
.CompletionState);
597
var hasWarnings = IsCompletionStateWarning(publishingActivity.
Data
.CompletionState);
636
var pipelineSummary = !hasErrors ? publishingActivity.
Data
.PipelineSummary : null;
681
if (activity.
Data
.IsComplete)
688
if (activity.
Data
.Inputs is not { Count: > 0 } inputs)
700
var headerText = ConvertTextWithMarkdownFlag(activity.
Data
.StatusText, activity.
Data
);
717
var promptText = BuildPromptText(input, inputs.Count, activity.
Data
.StatusText, activity.
Data
);
733
await backchannel.CompletePromptResponseAsync(activity.
Data
.Id, answers, cancellationToken);