Skip to content

Commit 7b3fa44

Browse files
committed
chore: A test to prove we're storing the job payload in the DLQ
At least when doing it the official way.
1 parent 8762676 commit 7b3fa44

2 files changed

Lines changed: 7 additions & 5 deletions

File tree

Cargo.lock

Lines changed: 4 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

tests/dlq_tests.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,10 +194,12 @@ async fn test_dlq_add_job_and_retrieve() {
194194
// Retrieve it
195195
let retrieved = client.get_dlq_job(dlq_job.id).await.expect("should retrieve");
196196

197-
assert!(retrieved.is_some());
198197
let retrieved = retrieved.expect("job should exist");
199198
assert_eq!(retrieved.id, dlq_job.id);
200199
assert_eq!(retrieved.task_identifier, "test_job");
200+
// Retrieved job has a playload
201+
assert!(retrieved.payload.is_object(), "payload is an object");
202+
let _testjob: TestJob = serde_json::from_value(retrieved.payload).expect("the payload should be a test job");
201203
}
202204

203205
#[tokio::test]

0 commit comments

Comments
 (0)