diff --git a/merlin-worker/src/main/java/gov/nasa/jpl/aerie/merlin/worker/postgres/PostgresProfileQueryHandler.java b/merlin-worker/src/main/java/gov/nasa/jpl/aerie/merlin/worker/postgres/PostgresProfileQueryHandler.java
index 69c25117b1..30d3a6956a 100644
--- a/merlin-worker/src/main/java/gov/nasa/jpl/aerie/merlin/worker/postgres/PostgresProfileQueryHandler.java
+++ b/merlin-worker/src/main/java/gov/nasa/jpl/aerie/merlin/worker/postgres/PostgresProfileQueryHandler.java
@@ -44,6 +44,7 @@ public PostgresProfileQueryHandler(DataSource dataSource, long datasetId) throws
     profileIds = new HashMap<>();
     profileDurations = new HashMap<>();
     this.datasetId = datasetId;
+    prepareStatements();
   }
 
   public void prepareStatements() throws SQLException {
@@ -78,7 +79,6 @@ on conflict (dataset_id, name) do nothing
    * */
   public void uploadResourceProfiles(final ResourceProfiles resourceProfiles) {
     try {
-      prepareStatements();
       // Add new profiles to DB
       for (final var realEntry : resourceProfiles.realProfiles().entrySet()) {
         if (!profileIds.containsKey(realEntry.getKey())) {