diff --git a/jobs/csharp/http/job-scheduler/Program.cs b/jobs/csharp/http/job-scheduler/Program.cs index 86697f35..d28bedfa 100644 --- a/jobs/csharp/http/job-scheduler/Program.cs +++ b/jobs/csharp/http/job-scheduler/Program.cs @@ -18,7 +18,7 @@ var r2d2JobBody = new }; var daprHost = Environment.GetEnvironmentVariable("DAPR_HOST") ?? "http://localhost"; -var schedulerDaprHttpPort = "6280"; +var jobServiceDaprHttpPort = "6280"; var httpClient = new HttpClient(); @@ -48,7 +48,7 @@ catch (Exception ex) async Task ScheduleJob(string jobName, object jobBody) { - var reqURL = $"{daprHost}:{schedulerDaprHttpPort}/v1.0-alpha1/jobs/{jobName}"; + var reqURL = $"{daprHost}:{jobServiceDaprHttpPort}/v1.0-alpha1/jobs/{jobName}"; var jsonBody = JsonSerializer.Serialize(jobBody); var content = new StringContent(jsonBody, Encoding.UTF8, "application/json"); @@ -64,7 +64,7 @@ async Task ScheduleJob(string jobName, object jobBody) async Task GetJobDetails(string jobName) { - var reqURL = $"{daprHost}:{schedulerDaprHttpPort}/v1.0-alpha1/jobs/{jobName}"; + var reqURL = $"{daprHost}:{jobServiceDaprHttpPort}/v1.0-alpha1/jobs/{jobName}"; var response = await httpClient.GetAsync(reqURL); diff --git a/jobs/go/http/job-scheduler/job-scheduler.go b/jobs/go/http/job-scheduler/job-scheduler.go index 2b7827d4..ecc0053c 100644 --- a/jobs/go/http/job-scheduler/job-scheduler.go +++ b/jobs/go/http/job-scheduler/job-scheduler.go @@ -35,7 +35,7 @@ func main() { daprHost = "http://localhost" } - schedulerDaprHttpPort := "6280" + jobServiceDaprHttpPort := "6280" client := http.Client{ Timeout: 15 * time.Second, @@ -43,7 +43,7 @@ func main() { // Schedule a job using the Dapr Jobs API with short dueTime jobName := "R2-D2" - reqURL := daprHost + ":" + schedulerDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName + reqURL := daprHost + ":" + jobServiceDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName req, err := http.NewRequest("POST", reqURL, strings.NewReader(r2d2JobBody)) if err != nil { @@ -71,7 +71,7 @@ func main() { // Schedule a job using the Dapr Jobs API with long dueTime jobName = "C-3PO" - reqURL = daprHost + ":" + schedulerDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName + reqURL = daprHost + ":" + jobServiceDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName req, err = http.NewRequest("POST", reqURL, strings.NewReader(c3poJobBody)) if err != nil { @@ -93,7 +93,7 @@ func main() { // Gets a job using the Dapr Jobs API jobName = "C-3PO" - reqURL = daprHost + ":" + schedulerDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName + reqURL = daprHost + ":" + jobServiceDaprHttpPort + "/v1.0-alpha1/jobs/" + jobName res, err = http.Get(reqURL) if err != nil { diff --git a/jobs/javascript/http/job-scheduler/index.js b/jobs/javascript/http/job-scheduler/index.js index dd256505..5f3d3279 100644 --- a/jobs/javascript/http/job-scheduler/index.js +++ b/jobs/javascript/http/job-scheduler/index.js @@ -13,7 +13,7 @@ const r2d2JobBody = { dueTime: "15s", }; const daprHost = process.env.DAPR_HOST || "http://localhost"; -const schedulerDaprHttpPort = "6280"; +const jobServiceDaprHttpPort = "6280"; async function main() { const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms)); @@ -45,7 +45,7 @@ async function main() { } async function scheduleJob(jobName, jobBody) { - const reqURL = `${daprHost}:${schedulerDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`; + const reqURL = `${daprHost}:${jobServiceDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`; const response = await fetch(reqURL, { method: "POST", headers: { @@ -64,7 +64,7 @@ async function scheduleJob(jobName, jobBody) { } async function getJobDetails(jobName) { - const reqURL = `${daprHost}:${schedulerDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`; + const reqURL = `${daprHost}:${jobServiceDaprHttpPort}/v1.0-alpha1/jobs/${jobName}`; const response = await fetch(reqURL, { method: "GET", }); diff --git a/jobs/python/http/README.md b/jobs/python/http/README.md index e2870a0a..cd711204 100644 --- a/jobs/python/http/README.md +++ b/jobs/python/http/README.md @@ -16,6 +16,11 @@ This quickstart includes two apps: - [Dapr CLI](https://docs.dapr.io/getting-started/install-dapr-cli/) - [Initialized Dapr environment](https://docs.dapr.io/getting-started/install-dapr-selfhost/) +## Environment Variables + +- `JOB_SERVICE_DAPR_HTTP_PORT`: The Dapr HTTP port of the job-service (default: 6280) +- `DAPR_HOST`: The Dapr host address (default: http://localhost) + ## Install dependencies