Get Redis Job Status

curl --request GET \
  --url https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "batchJobId": "<string>",
  "databaseStatus": "scheduled",
  "scheduledJobId": "<string>",
  "scheduledStartTime": "2023-11-07T05:31:56Z",
  "redisJobInfo": {
    "job_id": "<string>",
    "in_defer_queue": true,
    "job_metadata_exists": true,
    "scheduled_time": "2023-11-07T05:31:56Z",
    "note": "<string>"
  }
}

{
  "success": false,
  "error": "Invalid API key",
  "code": "invalid_api_key"
}

{
  "success": false,
  "error": "Error message",
  "code": "ERROR_CODE"
}

{
  "success": false,
  "error": "Error message",
  "code": "ERROR_CODE"
}

GET

batch

jobs

{batch_job_id}

redis-status

Get Redis Job Status

curl --request GET \
  --url https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.talkifai.dev/batch/jobs/{batch_job_id}/redis-status")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "batchJobId": "<string>",
  "databaseStatus": "scheduled",
  "scheduledJobId": "<string>",
  "scheduledStartTime": "2023-11-07T05:31:56Z",
  "redisJobInfo": {
    "job_id": "<string>",
    "in_defer_queue": true,
    "job_metadata_exists": true,
    "scheduled_time": "2023-11-07T05:31:56Z",
    "note": "<string>"
  }
}

{
  "success": false,
  "error": "Invalid API key",
  "code": "invalid_api_key"
}

{
  "success": false,
  "error": "Error message",
  "code": "ERROR_CODE"
}

{
  "success": false,
  "error": "Error message",
  "code": "ERROR_CODE"
}

Overview

Retrieves the Redis-side status of a scheduled batch job. This endpoint is primarily for debugging and troubleshooting scheduled jobs. Use this to:

Verify a scheduled job was created correctly
Check if job still exists in Redis before cancellation
Confirm job was removed after cancellation
Debug scheduling issues

This endpoint is for debugging purposes only. For normal operations, use Get Batch Job Detail.

Request

GET /batch/jobs/{batch_job_id}/redis-status

Path Parameters

Parameter	Type	Required	Description
`batch_job_id`	string	✅	Unique batch job identifier

Response

{
  "batchJobId": "batch_xyz789",
  "databaseStatus": "scheduled",
  "scheduledJobId": "arq_job_abc123",
  "scheduledStartTime": "2025-03-01T14:00:00Z",
  "redisJobInfo": {
    "job_id": "arq_job_abc123",
    "in_defer_queue": false,
    "job_metadata_exists": true,
    "scheduled_time": "2025-03-01T14:00:00+00:00",
    "note": "ARQ 0.26.3+ stores deferred jobs as individual keys, not in a defer queue"
  }
}

Response Fields

Field	Type	Description
`batchJobId`	string	Batch job ID
`databaseStatus`	string	Job status in database
`scheduledJobId`	string	Redis/ARQ job ID
`scheduledStartTime`	string	Scheduled time (ISO 8601, UTC)
`redisJobInfo`	object	Redis-side job information

Redis Job Info Object

Field	Type	Description
`job_id`	string	ARQ job identifier
`in_defer_queue`	boolean	Whether in defer queue (always false for ARQ 0.26.3+)
`job_metadata_exists`	boolean	Whether job key exists in Redis
`scheduled_time`	string	Scheduled execution time from Redis
`note`	string	Implementation note about ARQ version

Examples

Example 1: Check Scheduled Job Status

curl -X GET "https://api.talkifai.com/batch/jobs/batch_xyz789/redis-status" \
  -H "Authorization: Bearer YOUR_API_KEY"

Response (Job Exists):

{
  "batchJobId": "batch_xyz789",
  "databaseStatus": "scheduled",
  "scheduledJobId": "arq_job_abc123",
  "scheduledStartTime": "2025-03-01T14:00:00Z",
  "redisJobInfo": {
    "job_id": "arq_job_abc123",
    "in_defer_queue": false,
    "job_metadata_exists": true,
    "scheduled_time": "2025-03-01T14:00:00+00:00",
    "note": "ARQ 0.26.3+ stores deferred jobs as individual keys, not in a defer queue"
  }
}

Response (Job Not Found in Redis):

{
  "batchJobId": "batch_xyz789",
  "databaseStatus": "scheduled",
  "scheduledJobId": "arq_job_abc123",
  "scheduledStartTime": "2025-03-01T14:00:00Z",
  "redisJobInfo": {
    "job_id": "arq_job_abc123",
    "in_defer_queue": false,
    "job_metadata_exists": false,
    "scheduled_time": null,
    "note": "ARQ 0.26.3+ stores deferred jobs as individual keys, not in a defer queue"
  }
}

Example 2: Check Non-Scheduled Job

curl -X GET "https://api.talkifai.com/batch/jobs/batch_running/redis-status" \
  -H "Authorization: Bearer YOUR_API_KEY"

Response:

{
  "batchJobId": "batch_running",
  "databaseStatus": "running",
  "scheduledJobId": null,
  "scheduledStartTime": null,
  "redisJobInfo": null
}

Example 3: Debug Cancellation

Before cancelling a scheduled job, verify it exists:

# Check if job exists in Redis
curl -X GET "https://api.talkifai.com/batch/jobs/batch_xyz789/redis-status" \
  -H "Authorization: Bearer YOUR_API_KEY"

# If redisJobInfo.job_metadata_exists is true, proceed with cancellation
curl -X POST "https://api.talkifai.com/batch/jobs/batch_xyz789/cancel" \
  -H "Authorization: Bearer YOUR_API_KEY"

Interpretation Guide

Job Exists in Redis

{
  "redisJobInfo": {
    "job_metadata_exists": true,
    "scheduled_time": "2025-03-01T14:00:00+00:00"
  }
}

Meaning: Job is properly scheduled and will execute at the scheduled time.

Job Not Found in Redis

{
  "redisJobInfo": {
    "job_metadata_exists": false,
    "scheduled_time": null
  }
}

Possible causes:

Job already executed (dequeued by worker)
Job was cancelled previously
Database and Redis are out of sync
Job creation failed silently

No Scheduled Job ID

{
  "scheduledJobId": null,
  "redisJobInfo": null
}

Meaning: Job is not scheduled (either running, completed, pending, or was never scheduled).

Error Handling

404 Not Found

{
  "detail": "Batch job not found"
}

500 Internal Server Error

{
  "detail": "Failed to get Redis job status"
}

Troubleshooting

Issue: Job Shows “scheduled” But Never Started

Check Redis status:

curl -X GET "https://api.talkifai.com/batch/jobs/batch_xyz789/redis-status"

If job_metadata_exists is false:

Job may have been lost (Redis restart, crash)
Database and Redis are out of sync
Solution: Use Start Batch Job to manually start

Issue: Cancellation Returns “Job Not Found”

Check Redis status first:

curl -X GET "https://api.talkifai.com/batch/jobs/batch_xyz789/redis-status"

If job_metadata_exists is false:

Job already executed or was never in Redis
Cancellation will still update database
Expected behavior: redisJobCancelled: false in response

Issue: Scheduled Time Wrong

Verify timezone conversion:

curl -X GET "https://api.talkifai.com/batch/jobs/batch_xyz789/redis-status"

Compare scheduledStartTime (database) with redisJobInfo.scheduled_time (Redis):

They should match (within seconds)
If different, there may be a timezone conversion issue

Get Batch Job Detail — Get complete job info
Cancel Batch Job — Cancel a scheduled job
Reschedule Batch Job — Change scheduled time
Batch Calling Guide — Complete guide to batch campaigns

Authorizations

Authorization

string

header

required

Your TalkifAI API key. Get it from Studio â†’ Settings â†’ API Keys.

Path Parameters

batch_job_id

string

required

Response

Redis job status

batchJobId

string

databaseStatus

string

Example:

"scheduled"

scheduledJobId

string | null

scheduledStartTime

string<date-time> | null

redisJobInfo

object | null

Show child attributes

Reschedule Batch Job Custom Functions

Overview

Agents

Voice Calls

Export

Text Chat

Batch Calling

Custom Functions

Webhooks

Get Redis Job Status

Overview

Request

Path Parameters

Response

Response Fields

Redis Job Info Object

Examples

Example 1: Check Scheduled Job Status

Example 2: Check Non-Scheduled Job

Example 3: Debug Cancellation

Interpretation Guide

Job Exists in Redis

Job Not Found in Redis

No Scheduled Job ID

Error Handling

404 Not Found

500 Internal Server Error

Troubleshooting

Issue: Job Shows “scheduled” But Never Started

Issue: Cancellation Returns “Job Not Found”

Issue: Scheduled Time Wrong

Authorizations

Path Parameters

Response

​Overview

​Request

​Path Parameters

​Response

​Response Fields

​Redis Job Info Object

​Examples

​Example 1: Check Scheduled Job Status

​Example 2: Check Non-Scheduled Job

​Example 3: Debug Cancellation

​Interpretation Guide

​Job Exists in Redis

​Job Not Found in Redis

​No Scheduled Job ID

​Error Handling

​404 Not Found

​500 Internal Server Error

​Troubleshooting

​Issue: Job Shows “scheduled” But Never Started

​Issue: Cancellation Returns “Job Not Found”

​Issue: Scheduled Time Wrong

​Related

Authorizations

Path Parameters

Response

Overview

Request

Path Parameters

Response

Response Fields

Redis Job Info Object

Examples

Example 1: Check Scheduled Job Status

Example 2: Check Non-Scheduled Job

Example 3: Debug Cancellation

Interpretation Guide

Job Exists in Redis

Job Not Found in Redis

No Scheduled Job ID

Error Handling

404 Not Found

500 Internal Server Error

Troubleshooting

Issue: Job Shows “scheduled” But Never Started

Issue: Cancellation Returns “Job Not Found”

Issue: Scheduled Time Wrong

Related