Skip to content

Fixed Jobs SDK bugs #1456

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.

Sign up for GitHub

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

Merged
WhitWaldo merged 8 commits into from
Feb 11, 2025
Merged

Fixed Jobs SDK bugs #1456

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
1abb647
Fixed bug when setting point in time - this has to be set against Due…
WhitWaldo Feb 10, 2025
7a87753
Updated endpoint route builder to reflect expected job handler response
WhitWaldo Feb 10, 2025
ec231e4
Removed unused type
WhitWaldo Feb 10, 2025
1c67417
Updated example to use latest jobs bits
WhitWaldo Feb 10, 2025
bdcc98d
Updated XML docs
WhitWaldo Feb 10, 2025
2bf2bad
Updated documentation to reflect the change
WhitWaldo Feb 10, 2025
171d48b
Fixed unit tests
WhitWaldo Feb 10, 2025
a37a5a7
Slight performance improvement using StreamContent than MemoryStream
WhitWaldo Feb 11, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Fixed bug when setting point in time - this has to be set against Due… 
…Time property and not Schedule

Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
  • Loading branch information
@WhitWaldo
WhitWaldo committed Feb 10, 2025
commit 1abb647f0aac7422a20de3171c6bd6f9ebe9cec1
15 changes: 12 additions & 3 deletions src/Dapr.Jobs/DaprJobsGrpcClient.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -77,13 +77,22 @@ public override async Task ScheduleJobAsync(string jobName, DaprJobSchedule sche
ArgumentNullException.ThrowIfNull(jobName, nameof(jobName));
ArgumentNullException.ThrowIfNull(schedule, nameof(schedule));

var job = new Autogenerated.Job { Name = jobName, Schedule = schedule.ExpressionValue };
var job = new Autogenerated.Job { Name = jobName };

if (startingFrom is not null)
//Set up the schedule (recurring or point in time)
if (schedule.IsPointInTimeExpression)
{
job.DueTime = schedule.ExpressionValue;
}
else if (schedule.IsCronExpression || schedule.IsDurationExpression || schedule.IsPrefixedPeriodExpression)
{
job.Schedule = schedule.ExpressionValue;
}
else if (startingFrom is not null)
{
job.DueTime = ((DateTimeOffset)startingFrom).ToString("O");
}

if (repeats is not null)
{
if (repeats < 0)
Expand Down