diff --git a/servers/mu/src/domain/api/processSpawn.js b/servers/mu/src/domain/api/processSpawn.js
index df8e0941e..aa6c87355 100644
--- a/servers/mu/src/domain/api/processSpawn.js
+++ b/servers/mu/src/domain/api/processSpawn.js
@@ -38,7 +38,6 @@ export function processSpawnWith ({
          *
          * See: https://github.com/permaweb/ao/issues/730
          */
-        console.log({ res })
         return pullResult({
           processId: res.processTx,
           messageId: res.processTx,
@@ -77,7 +76,6 @@ export function processSpawnWith ({
       .map(setStage('pull-result', 'end'))
       .bimap(
         (e) => {
-          console.log(500)
           return new Error(e, { cause: e.cause })
         },
         logger.tap({ log: 'Successfully processed spawn', end: true })
diff --git a/servers/mu/src/domain/api/processSpawn.test.js b/servers/mu/src/domain/api/processSpawn.test.js
index b6dad8a78..f3518bafa 100644
--- a/servers/mu/src/domain/api/processSpawn.test.js
+++ b/servers/mu/src/domain/api/processSpawn.test.js
@@ -16,7 +16,6 @@ describe('processSpawnWith', () => {
       locateProcess: async () => ({ id: 'process-id', url: 'url-123' }),
       locateNoRedirect: async () => false,
       writeDataItem: async (item) => {
-        console.log(501, { item })
         return { ...item, id: 'id-123', timestamp: '1234567' }
       },
       buildAndSign: async (tx) => ({ ...tx, signed: true, data: 'data', id: 'id-123' }),
diff --git a/servers/mu/src/domain/clients/worker.js b/servers/mu/src/domain/clients/worker.js
index f8a0971f7..f38fc2d39 100644
--- a/servers/mu/src/domain/clients/worker.js
+++ b/servers/mu/src/domain/clients/worker.js
@@ -4,12 +4,12 @@ import { tap } from 'ramda'
 import cron from 'node-cron'
 
 import { createTaskQueue, enqueueWith, dequeueWith, removeDequeuedTasksWith } from './taskQueue.js'
-import { deleteOldTracesWith } from './cron.js'
 import { domainConfigSchema, config } from '../../config.js'
 // Without this import the worker crashes
 import { createResultApis } from '../../domain/index.js'
 import { createSqliteClient } from './sqlite.js'
 import { broadcastEnqueueWith, enqueueResultsWith, processResultWith, processResultsWith } from './worker-fn.js'
+import { deleteOldTracesWith } from './tracer.js'
 
 const broadcastChannel = new BroadcastChannel('mu-worker')
 
diff --git a/servers/mu/src/domain/dal.js b/servers/mu/src/domain/dal.js
index 967a6ceb6..7eef9ba05 100644
--- a/servers/mu/src/domain/dal.js
+++ b/servers/mu/src/domain/dal.js
@@ -174,7 +174,7 @@ export const fetchSchedulerProcessSchema = z.function()
         owner: processOwnerSchema,
         tags: tagArraySchema,
         timestamp: z.coerce.number(),
-        data: z.string(),
+        data: z.string().nullish(),
         anchor: z.string().nullish(),
         epoch: z.coerce.number().nullish(),
         nonce: z.coerce.number().nullish(),
diff --git a/servers/mu/src/domain/lib/pull-result.js b/servers/mu/src/domain/lib/pull-result.js
index 7bcfa413a..6cb02ebff 100644
--- a/servers/mu/src/domain/lib/pull-result.js
+++ b/servers/mu/src/domain/lib/pull-result.js
@@ -62,7 +62,6 @@ export function pullResultWith (env) {
   const fetchResult = fetchResultWith(env)
 
   return (ctx) => {
-    console.log(600, { ctx })
     if (!checkStage('pull-result')(ctx) && !checkStage('pull-initial-result')(ctx)) return Resolved(ctx)
     return of(ctx)
       .map((ctx) => ({ ...ctx, tx: ctx.tx }))