pub async fn checkpoint_with_transaction(
        &mut self,
        mut tx: sqlx::Transaction<'_, Postgres>,
        checkpoint: &Checkpoint<'_>,
    ) -> Result<(), sqlx::Error> {
        checkpoint.execute(self.id, &mut tx).await?;
        tx.commit().await?;
        Ok(())
    }
/// Checkpoint this job and commit the provided transaction at the same time.
/// If the transaction cannot be committed, the job will not be checkpointed.
/// Checkpointing allows the job payload to be replaced for the next retry.
Checkpoint this job and commit the provided transaction at the same time.
If the transaction cannot be committed, the job will not be checkpointed.
Checkpointing allows the job payload to be replaced for the next retry.
Checkpoint this job and commit the provided transaction at the same time . If the transaction cannot be committed the job will not be checkpointed . Checkpointing allows the job payload to be replaced for the next retry .
pub async fn checkpoint_with_transaction(
        &mut self,
        mut tx: sqlx::Transaction<'_, Postgres>,
        checkpoint: &Checkpoint<'_>,
    ) -> Result<(), sqlx::Error> {
        checkpoint.execute(self.id, &mut tx).await?;
        tx.commit().await?;
        Ok(())
    }
pub async fn checkpoint_with_transaction ( & mut self , mut tx : sqlx :: Transaction < ' _ , Postgres > , checkpoint : & Checkpoint < ' _ > , ) -> Result < ( ) , sqlx :: Error > { checkpoint . execute ( self . id , & mut tx ) . await ? ; tx . commit ( ) . await ? ; Ok ( ( ) ) }
Checkpoint this job and commit the provided transaction at the same time.
Checkpoint this job and commit the provided transaction at the same time .
&mut self
tx
sqlx::Transaction<'_, Postgres>
checkpoint
&Checkpoint<'_>
&mut self
tx
sqlx::Transaction<'_, Postgres>
checkpoint
&Checkpoint<'_>