10 implementations of CompleteAsync
Aspire.Hosting (2)
Pipelines\NullPipelineActivityReporter.cs (1)
90public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Pipelines\ReportingTask.cs (1)
63public async Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Azure.Kubernetes.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Azure.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Docker.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Foundry.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Java.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Kubernetes.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Rust.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
Aspire.Hosting.Tests (1)
tests\Shared\TestPipelineActivityReporter.cs (1)
270public Task CompleteAsync(string? completionMessage = null, CompletionState completionState = CompletionState.Completed, CancellationToken cancellationToken = default)
60 references to CompleteAsync
Aspire.Hosting (4)
Ats\PipelineExports.cs (1)
175return reportingTask.CompleteAsync(completionMessage, ParseCompletionState(completionState), cancellationToken);
Publishing\PublishingExtensions.cs (3)
155await task.CompleteAsync(message, CompletionState.Completed, cancellationToken).ConfigureAwait(false); 187await task.CompleteAsync(message, CompletionState.CompletedWithWarning, cancellationToken).ConfigureAwait(false); 219await task.CompleteAsync(errorMessage, CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure (3)
AzureEnvironmentResource.cs (2)
317await discoveryTask.CompleteAsync( 375await deleteTask.CompleteAsync(
AzurePublishingContext.cs (1)
387await computeEnvironmentTask.CompleteAsync(message, state, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Sandboxes (4)
AzureSandboxContainerDeployment.cs (4)
312await diskTask.CompleteAsync($"Created sandbox disk image {diskImageId}", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false); 338await createTask.CompleteAsync($"Created sandbox {sandboxId}", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false); 351await lifecycleTask.CompleteAsync("Lifecycle policy configured", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false); 1466await cleanupTask.CompleteAsync($"Deleted stale sandbox deployment {sectionName}", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Docker (2)
DockerComposeEnvironmentResource.cs (2)
465await deployTask.CompleteAsync($"Compose deployment failed ({runtime.Name}): {ex.Message}", CompletionState.CompletedWithError, context.CancellationToken).ConfigureAwait(false); 503await deployTask.CompleteAsync($"Compose shutdown failed ({runtime.Name}): {ex.Message}", CompletionState.CompletedWithError, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Kubernetes (3)
Deployment\HelmDeploymentEngine.cs (3)
275await prepareTask.CompleteAsync( 501await deployTask.CompleteAsync( 646await uninstallTask.CompleteAsync(
Aspire.Hosting.Radius (2)
Publishing\RadiusBicepPublishingContext.cs (1)
107await task.CompleteAsync(
Publishing\RadiusDeploymentPipelineStep.cs (1)
637await deployTask.CompleteAsync(
Aspire.Hosting.Tests (20)
Publishing\PipelineActivityReporterTests.cs (20)
290await task.CompleteAsync(completionMessage, cancellationToken: CancellationToken.None); 323() => task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None)); 384await task1.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 388await task2.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 392await task3.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 420await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 437await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 443await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 462await task.CompleteAsync((string?)null, CompletionState.Completed, cancellationToken: CancellationToken.None); 468await task.CompleteAsync("Error", CompletionState.CompletedWithError, cancellationToken: CancellationToken.None); 537await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 550await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); // Should not throw 551await task.CompleteAsync("Error", CompletionState.CompletedWithError, cancellationToken: CancellationToken.None); // Should also not throw (noop) 1127await task.CompleteAsync(markdownCompletionMessage, cancellationToken: CancellationToken.None); 1229await task.CompleteAsync("Warning message", CompletionState.CompletedWithWarning, CancellationToken.None); 1235await task.CompleteAsync("Different warning message", CompletionState.CompletedWithWarning, CancellationToken.None); 1254await task.CompleteAsync("Error message", CompletionState.CompletedWithError, CancellationToken.None); 1260await task.CompleteAsync("Different error message", CompletionState.CompletedWithError, CancellationToken.None); 1333await task.CompleteAsync("First completion", firstState, CancellationToken.None); 1339await task.CompleteAsync("Second completion", secondState, CancellationToken.None);
Pipelines.AppHost (12)
AppHost.cs (12)
84await assignRoleTask.CompleteAsync( 99await assignRoleTask.CompleteAsync( 119await assignRoleTask.CompleteAsync( 134await assignRoleTask.CompleteAsync( 154await assignRoleTask.CompleteAsync( 169await assignRoleTask.CompleteAsync( 192await assignRoleTask.CompleteAsync( 204await assignRoleTask.CompleteAsync( 211await assignRoleTask.CompleteAsync( 218await assignRoleTask.CompleteAsync( 270await uploadTask.CompleteAsync( 315await uploadTask.CompleteAsync(
Pipelines.Library (7)
DistributedApplicationPipelineExtensions.cs (7)
83await publishTask.CompleteAsync( 95await publishTask.CompleteAsync( 102await publishTask.CompleteAsync( 114await zipTask.CompleteAsync( 132await uploadTask.CompleteAsync( 158await uploadTask.CompleteAsync( 165await uploadTask.CompleteAsync(
SimplePipelines.AppHost (3)
AppHost.cs (3)
16await task.CompleteAsync( 34await task.CompleteAsync( 52await task.CompleteAsync(