-
Notifications
You must be signed in to change notification settings - Fork 530
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Added Dapr Jobs .NET Quickstart #1131
Draft
WhitWaldo
wants to merge
9
commits into
dapr:release-1.15
Choose a base branch
from
WhitWaldo:jobs-dotnet
base: release-1.15
Could not load branches
Branch not found: {{ refName }}
Loading
Could not load tags
Nothing to show
Loading
Are you sure you want to change the base?
Some commits from the old base branch may be removed from the timeline,
and old review comments may become outdated.
Draft
Changes from all commits
Commits
Show all changes
9 commits
Select commit
Hold shift + click to select a range
dd8169a
Adding first pass of the jobs quickstart functionality
WhitWaldo 6a7923d
Removed dapr run file
WhitWaldo 5b1bdaf
Updated schedule to make it more.. demonstrable
WhitWaldo 5280fc3
Added README as much as possible until bug (https://github.com/dapr/d…
WhitWaldo e3c5fb0
Updated to latest RC package (1.15.0-rc02)
WhitWaldo ee6ad9b
Fixed possible typo in STEP markup
WhitWaldo 618da4c
Merge branch 'release-1.15' into jobs-dotnet
WhitWaldo fdc2bea
Targeting .NET 8 instead
WhitWaldo 07eb19b
Merge branch 'release-1.15' into jobs-dotnet
WhitWaldo File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,10 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk.Web"> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net8.0</TargetFramework> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| </PropertyGroup> | ||
|
|
||
| </Project> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| var builder = WebApplication.CreateBuilder(args); | ||
|
|
||
| var app = builder.Build(); | ||
|
|
||
| app.MapGet("/etl/{taskId}", async (ILogger<Program> logger, Guid taskId) => | ||
| { | ||
| Log.LogEtlStart(logger, taskId); | ||
|
|
||
| //Simulate running some sort of ETL operation | ||
| await Task.Delay(TimeSpan.FromSeconds(7)); | ||
|
|
||
| return TypedResults.Ok; | ||
| }); | ||
|
|
||
| await app.RunAsync(); | ||
|
|
||
| static partial class Log | ||
| { | ||
| [LoggerMessage(LogLevel.Information, "Starting task {taskId} on service")] | ||
| public static partial void LogEtlStart(ILogger logger, Guid taskId); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,28 @@ | ||
| | ||
| Microsoft Visual Studio Solution File, Format Version 12.00 | ||
| # Visual Studio Version 17 | ||
| VisualStudioVersion = 17.0.31903.59 | ||
| MinimumVisualStudioVersion = 10.0.40219.1 | ||
| Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JobsApp", "JobsApp/JobsApp.csproj", "{4F0E7704-CB1D-48E8-A357-9E33FB7003D5}" | ||
| EndProject | ||
| Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EtlService", "EtlService\EtlService.csproj", "{797B142F-3AA3-4EEF-B718-227AEADED508}" | ||
| EndProject | ||
| Global | ||
| GlobalSection(SolutionConfigurationPlatforms) = preSolution | ||
| Debug|Any CPU = Debug|Any CPU | ||
| Release|Any CPU = Release|Any CPU | ||
| EndGlobalSection | ||
| GlobalSection(SolutionProperties) = preSolution | ||
| HideSolutionNode = FALSE | ||
| EndGlobalSection | ||
| GlobalSection(ProjectConfigurationPlatforms) = postSolution | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Debug|Any CPU.Build.0 = Debug|Any CPU | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Release|Any CPU.ActiveCfg = Release|Any CPU | ||
| {4F0E7704-CB1D-48E8-A357-9E33FB7003D5}.Release|Any CPU.Build.0 = Release|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Debug|Any CPU.ActiveCfg = Debug|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Debug|Any CPU.Build.0 = Debug|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Release|Any CPU.ActiveCfg = Release|Any CPU | ||
| {797B142F-3AA3-4EEF-B718-227AEADED508}.Release|Any CPU.Build.0 = Release|Any CPU | ||
| EndGlobalSection | ||
| EndGlobal |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,15 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk.Web"> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net8.0</TargetFramework> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <PackageReference Include="Dapr.AspNetCore" Version="1.15.0-rc02" /> | ||
| <PackageReference Include="Dapr.Jobs" Version="1.15.0-rc02" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| namespace JobsApp.Models; | ||
|
|
||
| internal sealed record JobEtlPayload(string AppId, string TaskId); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,67 @@ | ||
| using System.Text.Json; | ||
| using Dapr.Client; | ||
| using Dapr.Jobs; | ||
| using Dapr.Jobs.Extensions; | ||
| using Dapr.Jobs.Models; | ||
| using Dapr.Jobs.Models.Responses; | ||
| using JobsApp.Models; | ||
|
|
||
| // The jobs host is a background service that connects to the sidecar over gRPC | ||
| var builder = WebApplication.CreateBuilder(args); | ||
|
|
||
| builder.Services.AddDaprClient(); | ||
| builder.Services.AddDaprJobsClient(); | ||
|
|
||
| var app = builder.Build(); | ||
|
|
||
| //Set up a handler to capture incoming jobs | ||
| var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(60)); | ||
| app.MapDaprScheduledJobHandler(async ( | ||
| string? jobName, | ||
| DaprJobDetails? jobDetails, | ||
| ILogger? logger, | ||
| DaprClient daprClient, | ||
| CancellationToken cancellationToken) => | ||
| { | ||
| var payload = JsonSerializer.Deserialize<JobEtlPayload>(jobDetails?.Payload); | ||
|
|
||
| if (logger is not null) | ||
| Log.LogJobInvocation(logger, jobName, payload); | ||
|
|
||
| if (payload is null) | ||
| { | ||
| if (logger is not null) | ||
| Log.LogPaylodNotAvailable(logger); | ||
| throw new Exception("Unable to deserialize the payload from the scheduled job invocation"); | ||
| } | ||
|
|
||
| await daprClient.InvokeMethodAsync(HttpMethod.Get, "etl-svc", $"/etl/{payload.TaskId}", cancellationToken); | ||
| }, cancellationTokenSource.Token); | ||
|
|
||
| //Schedule with the Dapr Jobs client | ||
| var jobsClient = app.Services.GetRequiredService<DaprJobsClient>(); | ||
| var logger = app.Services.GetRequiredService<ILogger<Program>>(); | ||
|
|
||
| //Create a Cron expression to run four times a minute on the 15-second marks | ||
| var cronBuilder = new CronExpressionBuilder() | ||
| .On(OnCronPeriod.Second, 15); | ||
|
|
||
| //Schedule ETL job to run for only four invocations | ||
| var payload = new JobEtlPayload("etl-svc", "op-109780792"); | ||
| const string nameOfJob = "daily-etl"; | ||
| await jobsClient.ScheduleJobWithPayloadAsync(nameOfJob, DaprJobSchedule.FromCronExpression(cronBuilder), payload, DateTime.Now, 4); | ||
| Log.LogJobSchedule(logger, nameOfJob, payload); | ||
|
|
||
| await app.RunAsync(); | ||
|
|
||
| static partial class Log | ||
| { | ||
| [LoggerMessage(LogLevel.Information, "Scheduled job '{jobName}' with payload {payload}")] | ||
| public static partial void LogJobSchedule(ILogger logger, string jobName, JobEtlPayload payload); | ||
|
|
||
| [LoggerMessage(LogLevel.Information, "Unable to deserialize the payload from the scheduled job invocation")] | ||
| public static partial void LogPaylodNotAvailable(ILogger logger); | ||
|
|
||
| [LoggerMessage(LogLevel.Information, "ETL job invoked: {jobName} with payload {payload}")] | ||
| public static partial void LogJobInvocation(ILogger logger, string? jobName, JobEtlPayload? payload); | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,127 @@ | ||
| # Dapr jobs | ||
|
|
||
| In this quickstart, you'll create two microservices that demonstrate how the Jobs API can be readily utilized in | ||
| a .NET application. The Jobs App will schedule the job and will handle its invocation when triggered, sending a | ||
| message to another microservice to simulate some sort of operation. | ||
|
|
||
| Visit [this link](https://docs.dapr.io/developing-applications/building-blocks/jobs/jobs-overview/) for more | ||
| information about the Dapr Jobs API. | ||
|
|
||
| This quickstart includes the following two services: | ||
| - Schedules Jobs and handles job invocations: `JobsApp` | ||
| - Receives service invocation and simulates ETL operation: `EtlService` | ||
|
|
||
| ## Run the quickstart | ||
| 1. Open a new terminal window and launch the ETL service with the following command: | ||
|
|
||
| <!-- STEP | ||
| name: Run ETL service | ||
| expected_stdout_lines: | ||
| - 'Starting Dapr with id etl-svc.' | ||
| - 'Updating metadata for app command: dotnet run --project ./EtlService/EtlService.csproj --urls=http://localhost:5001' | ||
| - 'You're up and running! Both Dapr and your app logs will appear here.' | ||
| output_match_mode: substring | ||
| match_order: none | ||
| background: true | ||
| sleep: 15 | ||
| timeout_seconds: 45 | ||
| --> | ||
|
|
||
| ```bash | ||
| dapr run --app-id etl-svc -- dotnet run --project ./EtlService/EtlService.csproj --urls=http://localhost:5001 | ||
| ``` | ||
| The terminal console should show standard startup logs like the following since the app will start, but then wait until | ||
| the service is invoked: | ||
|
|
||
| ```text | ||
| Starting Dapr with id etl-svc. HTTP Port: 50737. gRPC Port: 50738 | ||
| Checking if Dapr sidecar is listening on HTTP port 50737 | ||
| Flag --components-path has been deprecated, use --resources-path | ||
| Flag --dapr-http-max-request-size has been deprecated, use '--max-body-size 4Mi' | ||
| Flag --dapr-http-read-buffer-size has been deprecated, use '--read-buffer-size 4Ki' | ||
| time="2025-01-15T09:44:15.8139364-06:00" level=info msg="Starting Dapr Runtime -- version 1.15.0-rc.1 -- commit fdd642e96ac06163b30ef1db751a403351887dc9" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8139364-06:00" level=info msg="Log level set to: info" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8139364-06:00" level=warning msg="mTLS is disabled. Skipping certificate request and tls validation" app_id=etl-svc instance=Incubus scope=dapr.runtime.security type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8155037-06:00" level=info msg="metric spec: {\"enabled\":true}" app_id=etl-svc instance=Incubus scope=dapr.runtime.diagnostics type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8155037-06:00" level=info msg="Using default latency distribution buckets: [1 2 3 4 5 6 8 10 13 16 20 25 30 40 50 65 80 100 130 160 200 250 300 400 500 650 800 1000 2000 5000 10000 20000 50000 100000]" app_id=etl-svc instance=Incubus scope=dapr.runtime.diagnostics type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8155037-06:00" level=warning msg="The default value for 'spec.metric.http.increasedCardinality' will change to 'false' in Dapr 1.15 or later" app_id=etl-svc instance=Incubus scope=dapr.runtime.diagnostics type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8164977-06:00" level=info msg="standalone mode configured" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8164977-06:00" level=info msg="app id: etl-svc" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="Scheduler client initialized for address: localhost:6060" app_id=etl-svc instance=Incubus scope=dapr.runtime.scheduler.clients type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="Scheduler clients initialized" app_id=etl-svc instance=Incubus scope=dapr.runtime.scheduler.clients type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="Dapr trace sampler initialized: ParentBased{root:AlwaysOnSampler,remoteParentSampled:AlwaysOnSampler,remoteParentNotSampled:AlwaysOffSampler,localParentSampled:AlwaysOnSampler,localParentNotSampled:AlwaysOffSampler}" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8171436-06:00" level=info msg="metrics server started on :50739/" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8483454-06:00" level=info msg="local service entry announced: etl-svc -> 192.168.2.38:50740" app_id=etl-svc component="nr (mdns/v1)" instance=Incubus scope=dapr.contrib type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8539638-06:00" level=info msg="Initialized name resolution to mdns" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8545343-06:00" level=info msg="Loading components…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8556398-06:00" level=info msg="Waiting for all outstanding components to be processed…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8556398-06:00" level=info msg="All outstanding components processed" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8561666-06:00" level=info msg="Loading endpoints…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.856722-06:00" level=info msg="Waiting for all outstanding http endpoints to be processed…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.856722-06:00" level=info msg="All outstanding http endpoints processed" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.856722-06:00" level=info msg="Loading Declarative Subscriptions…" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8572499-06:00" level=warning msg="App channel is not initialized. Did you configure an app-port?" app_id=etl-svc instance=Incubus scope=dapr.runtime.channels type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8577923-06:00" level=info msg="gRPC server listening on TCP address: :50738" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8577923-06:00" level=info msg="Enabled gRPC tracing middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8577923-06:00" level=info msg="Enabled gRPC metrics middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=info msg="Registering workflow engine for gRPC endpoint: [::]:50738" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.api type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=info msg="API gRPC server is running on port 50738" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=warning msg="The default value for 'spec.metric.http.increasedCardinality' will change to 'false' in Dapr 1.15 or later" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8583182-06:00" level=info msg="Enabled max body size HTTP middleware with size 4194304 bytes" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8588281-06:00" level=info msg="Enabled tracing HTTP middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8588281-06:00" level=info msg="Enabled metrics HTTP middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8595557-06:00" level=info msg="HTTP server listening on TCP address: :50737" app_id=etl-svc instance=Incubus scope=dapr.runtime.http type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8595557-06:00" level=info msg="HTTP server is running on port 50737" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8595557-06:00" level=info msg="The request body size parameter is: 4194304 bytes" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="gRPC server listening on TCP address: :50740" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.internal type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="Enabled gRPC tracing middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.internal type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="Enabled gRPC metrics middleware" app_id=etl-svc instance=Incubus scope=dapr.runtime.grpc.internal type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.860102-06:00" level=info msg="Internal gRPC server is running on :50740" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8606266-06:00" level=info msg="actors: state store is not configured - this is okay for clients but services with hosted actors will fail to initialize!" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8611851-06:00" level=info msg="Configuring actors placement provider 'placement'. Configuration: 'placement:localhost:6050'" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8611851-06:00" level=info msg="Configuring actor reminders provider 'default'. Configuration: ''" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8611851-06:00" level=info msg="Actor runtime started. Idle timeout: 1h0m0s" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8616921-06:00" level=info msg="Configuring workflow engine with actors backend" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8617175-06:00" level=info msg="Registering component for dapr workflow engine..." app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8617175-06:00" level=info msg="Initializing Dapr workflow component" app_id=etl-svc component="dapr (workflow.dapr/v1)" instance=Incubus scope=dapr.contrib type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8617175-06:00" level=info msg="Workflow engine initialized." app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.862781-06:00" level=info msg="dapr initialized. Status: Running. Init Elapsed 46ms" app_id=etl-svc instance=Incubus scope=dapr.runtime type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8627966-06:00" level=info msg="Scheduler stream connected" app_id=etl-svc instance=Incubus scope=dapr.runtime.scheduler type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8924449-06:00" level=info msg="Actor API level in the cluster has been updated to 10" app_id=etl-svc instance=Incubus scope=dapr.runtime.actor type=log ver=1.15.0-rc.1 | ||
| time="2025-01-15T09:44:15.8924449-06:00" level=info msg="Placement tables updated, version: 9" app_id=etl-svc instance=Incubus scope=dapr.runtime.actors.placement type=log ver=1.15.0-rc.1 | ||
| Checking if Dapr sidecar is listening on GRPC port 50738 | ||
| Dapr sidecar is up and running. | ||
| Updating metadata for appPID: 41396 | ||
| Updating metadata for app command: dotnet run --project ./EtlService/EtlService.csproj --urls=http://localhost:5001 | ||
| You're up and running! Both Dapr and your app logs will appear here. | ||
| ``` | ||
|
|
||
| 2. Open a second terminal window and launch the Jobs app with the following command: | ||
|
|
||
| <!-- STEP | ||
| name: Run Jobs App service | ||
| expected-stdout_lines: | ||
| - 'Starting Dapr with id job-app.' | ||
| - 'Updating metadata for app command: dotnet run --project ./JobsApp/JobsApp.csproj --urls=http://localhost:5002' | ||
| - 'You're up and running! Both Dapr and your app logs will appear here.' | ||
| output_match_mode: substring | ||
| match_order: none | ||
| background: true | ||
| sleep: 15 | ||
| timeout_seconds: 45 | ||
| --> | ||
|
|
||
| ```bash | ||
| dapr run --app-id jobs-app -- dotnet run --project ./JobsApp/JobsApp.csproj --urls=http://localhost:5002 | ||
| ``` | ||
|
|
||
| As with the other application, the terminal console should show standard startup logs, but will then proceed to show your | ||
| application logs as the job is scheduled: | ||
|
|
||
| ```text | ||
| You're up and running! Both Dapr and your app logs will appear here. | ||
|
|
||
|
|
||
| ``` | ||
|
|
||
| 3. When you're finished, hit Ctrl + C in both terminals to stop and clean up the application processes |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,2 @@ | ||
| include ../../../docker.mk | ||
| include ../../../validate.mk |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what do you think about using the "http proxy" approach to invoking the http call instead like we do in the basic service invoke quickstart? https://docs.dapr.io/getting-started/quickstarts/serviceinvocation-quickstart/
that shows you can keep using your favorite HTTP client and just pass a header, making dapr look a bit more familiar.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also can we sync to
release-1.15and try to get these C# checks to pass?There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
As this was the SDK quickstart, I opted to use the SDK-style service invocation instead of
HttpClientas I figured that was better featured in the HTTP quickstart.A sync to release-1.15 does not appear to be in the cards for me until all my PRs are closed. As best I can tell I'm going to have to delete my GitHub fork and re-create it to get it to sync anything but master (as it's the only branch I originally forked).