fix: Use the type alias I defined

PostHog · Nov 30, 2023 · f556bea · f556bea
1 parent c6ab642
commit f556bea
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/hook-common/src/pgqueue.rs b/hook-common/src/pgqueue.rs
@@ -74,7 +74,16 @@ pub struct Job<J> {
     /// The current status of the job.
     pub status: JobStatus,
     /// Arbitrary job parameters stored as JSON.
-    pub parameters: sqlx::types::Json<J>,
+    pub parameters: JobParameters<J>,
+}
+
+/// A NewJob to be enqueued into a PgQueue.
+pub struct RetryableJob<J> {
+    pub attempt: i32,
+    pub finished_at: Option<DateTime<Utc>>,
+    pub started_at: Option<DateTime<Utc>>,
+    pub status: JobStatus,
+    pub parameters: JobParameters<J>,
 }
 
 /// A NewJob to be enqueued into a PgQueue.
@@ -83,7 +92,7 @@ pub struct NewJob<J> {
     pub finished_at: Option<DateTime<Utc>>,
     pub started_at: Option<DateTime<Utc>>,
     pub status: JobStatus,
-    pub parameters: sqlx::types::Json<J>,
+    pub parameters: JobParameters<J>,
 }
 
 impl<J> NewJob<J> {