A couple of suggested tweaks

Author: ericallam

apps/webapp/app/services/runsReplicationService.server.ts

@@ -385,7 +385,13 @@ export class RunsReplicationService {
       lastAcknowledgedAt: this._lastAcknowledgedAt,
     });
 
-    await this._replicationClient.acknowledge(this._latestCommitEndLsn);
+    const [ackError] = await tryCatch(
+      this._replicationClient.acknowledge(this._latestCommitEndLsn)
+    );
+
+    if (ackError) {
+      this.logger.error("Error acknowledging transaction", { ackError });
+    }
 
     if (this._isShutDownComplete && this._acknowledgeInterval) {
       clearInterval(this._acknowledgeInterval);

internal-packages/replication/src/pgoutput.ts

@@ -156,7 +156,6 @@ class BinaryReader {
   readTime(): bigint {
     // (POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * USECS_PER_DAY == 946684800000000
     const microsSinceUnixEpoch = this.readUint64() + 946684800000000n;
-    // Convert to milliseconds for JS Date compatibility
     return microsSinceUnixEpoch;
   }
 }