diff --git a/observer/bin/migrate.js b/observer/bin/migrate.js
index 3785028..01924ed 100644
--- a/observer/bin/migrate.js
+++ b/observer/bin/migrate.js
@@ -1,5 +1,13 @@
-import { getStats } from '../../common/db.js'
+import { getPgPools } from '../../common/db.js'
+import { migrateWithPgClient as migrateEvaluateDB } from 'spark-evaluate/lib/migrate.js'
 import { migrateWithPgClient as migrateStatsDB } from '@filecoin-station/spark-stats-db-migrations'
 
+const pgPools = await getPgPools()
+
+console.log('Migrating spark_evaluate database')
+await migrateEvaluateDB(pgPools.evaluate)
+
 console.log('Migrating spark_stats database')
-await migrateStatsDB(await getStats())
+await migrateStatsDB(pgPools.stats)
+
+await pgPools.end()