You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
publicstatic Job Convert(JobDefinitionjob){varretry= job.retryPolicy.GetOrThrow(()=>new Exception("Job definition has no retry policy"));varj=new Job(){id= job.id.GetOrThrow(()=>new Exception("Job definition has no id.")),action= job.jobAction.Convert(),triggers= job.triggers.Select(t => t.Convert()).ToList(),source= job.source.GetOrThrow(()=>new Exception("Job definition has no source")),name= job.name.GetOrThrow(()=>new Exception("Job definition has no name")),owner= job.owner.GetOrThrow(()=>new Exception("Job definition has no owner")),retryPolicy=new RetryPolicy
{maxRetryCount= retry.maxRetryCount.GetOrThrow(()=>new Exception("Retry policy has no maxRetryCount")),retryDelayMs= retry.retryDelayMs.GetOrThrow(()=>new Exception("Retry policy has no retryDelayMs")),useExponentialBackoff= retry.useExponentialBackoff.GetOrThrow(()=>new Exception("Retry policy has no useExponentialBackoff")),}};returnj;}
And of note, the job.source.GetOrThrow(() => new Exception("Job definition has no source")), is invalid, because source is actually an optional field, even though it isn't stated as such in the open-api spec.
If the source is NONE, then "null" is the valid value.
The text was updated successfully, but these errors were encountered:
The
BeamScheduler
class has this segment,And of note, the
job.source.GetOrThrow(() => new Exception("Job definition has no source")),
is invalid, becausesource
is actually an optional field, even though it isn't stated as such in the open-api spec.If the
source
is NONE, then"null"
is the valid value.The text was updated successfully, but these errors were encountered: