@runlane/core - npm Package Compare versions

Comparing version

0.2.0

0.3.0

+1

-1

dist/index.d.cts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"index.d.cts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime/lease-timing.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;;UCa5C,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;;iBAMpB,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;;;ADtB7E;UEHiB,WAAA;;;;WAIN,mBAAA;EFDmC;;AAAe;EAAf,SEKnC,eAAe;AAAA;;;;;;aCHd,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;;AHT2D;aGejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EFba;AAAA;AAMpC;;EANoC,SEkBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;;AJCxB;;UIIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;;AJPkD;;KIajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;;AHXY;AAMpC;KGWY,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;;KAMH,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;;KAKhB,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCrC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;;ALhBxF;;UKuBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;;AJnCiB;AAMpC;;;;;UIuCiB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;;;;iBAkH7B,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cC9LZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;ANJzC;;;AAAA,KMWY,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;;ANpBwD;UOuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;;APhDzD;UQ2BiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;;AR9B8B;UQoC5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;AAAA;;;;KAMP,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;;cAQ5B,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;cCapB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAmBzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;AN/E9B;AAMZ;;AANY,KMiGA,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;;KAQ/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAY9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;ALhJR;KKuJlB,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;ALlI5C;;;AAAA,KK0IY,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;AT5L9C;;;AAAA,UU2DiB,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAahD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,EAAU,IAAA;EAAA;EAAA,SAEZ,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC5EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAA;EAAA,SACzB,WAAA;EV1BiB;;AAAQ;EAAR,SU8BjB,aAAA,IAAiB,GAAA,EAAK,SAAA,KAAc,SAAA;AAAA;;;;;;;UAS9B,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;AT5D7B;;;;AAQ0B;;AAR1B,USqEiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;;;UAKjD,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCwDJ,2BAAA,EAA2B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cA0B3B,sBAAA,EAAsB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cAWtB,yBAAA,EAAyB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAkCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,2BAAA;;;;KAKnC,aAAA,GAAgB,CAAA,CAAE,KAAK,QAAQ,sBAAA;;;;KAK/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,KAO9C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,UAAA,gBAA0B,SAAA,kCAA2C,MAAA,IACrE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,aAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,aAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;;UAMW,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;;;AH5NxB;WGgOW,eAAA,EAAiB,yBAAA;;;;WAIjB,IAAA,EAAM,IAAA;;;;WAIN,MAAA,WAAiB,iBAAA;;;;WAIjB,IAAA,EAAM,cAAA;;;;;;WAMN,KAAA,EAAO,MAAA;;;;EAIhB,KAAA,IAAS,OAAA;;;;EAIT,KAAA,IAAS,OAAA;;;;EAIT,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,gBAAA;;;;EAIX,MAAA,kBAAwB,SAAA,6BAAsC,SAAA,cAC5D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,UAAA,CAAW,MAAA,IACnB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;;;;EAIrC,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;;;;EAIrF,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;;;;EAItD,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA0NnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC7jBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;;cAK1B,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;AbPU;;KaYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}
		{"version":3,"file":"index.d.cts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime/lease-timing.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/signals-api.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;;UCe5C,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;;iBAMpB,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;;;ADxB7E;UEHiB,WAAA;;;;WAIN,mBAAA;EFDmC;;AAAe;EAAf,SEKnC,eAAe;AAAA;;;;;;aCHd,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;;AHT2D;aGejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EFXa;AAAA;AAMpC;;EANoC,SEgBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;;AJCxB;;UIIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;;AJPkD;;KIajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;;AHTY;AAMpC;KGSY,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;;KAMH,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;;KAKhB,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCnC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;;ALlBxF;;UKyBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,kBAAA,GAAqB,cAAA;EAAA,SACrB,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;AJpCiB;AAMpC;;;;;;AANoC,UI8CnB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,kBAAA,GAAqB,cAAA;EAAA,SACrB,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;AF1DpC;AAMT;;AANS,iBE2KO,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cCjMZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;ANJzC;;;AAAA,KMWY,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;;ANpBwD;UOuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;;APhDzD;UQqCiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;;ARxC8B;UQ8C5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;EAAA,SACR,iBAAA,WAA4B,SAAA;AAAA;;;;KAM3B,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;APvCL;cO+CvB,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;;cCEpB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAmBzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;AN/E9B;AAMZ;;AANY,KMiGA,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;;KAQ/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAY9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;ALhJR;KKuJlB,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;ALlI5C;;;AAAA,KK0IY,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;cC3KxC,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;AVjBhC;;KU0BY,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;UAK9B,iBAAA;EACf,IAAA,CAAK,SAAA,EAAW,cAAA,EAAgB,OAAA,GAAU,iBAAA,GAAoB,OAAA,UAAiB,SAAA;AAAA;;;;AVhCjF;;UW8DiB,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAWhD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,MAAA,GAAS,SAAA;EAAA,SACT,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,GAAW,IAAA;IAAA,SACX,IAAA,GAAO,wBAAA;EAAA;EAAA,SAET,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC/EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAA;EAAA,SACzB,WAAA;EXxBiB;;AAAQ;EAAR,SW4BjB,aAAA,IAAiB,GAAA,EAAK,SAAA,KAAc,SAAA;AAAA;;;;;;;UAS9B,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;AV5D7B;;;;AAQ0B;;AAR1B,UUqEiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;;;UAKjD,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCuGJ,sBAAA,EAAsB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cActB,yBAAA,EAAyB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAwB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,yBAAyB;;;;KAK7C,aAAA,GAAgB,CAAA,CAAE,KAAK,QAAQ,sBAAA;AJzN3C;;;AAAA,KI8NY,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,KAO9C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,UAAA,gBAA0B,SAAA,kCAA2C,MAAA,IACrE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,aAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,aAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;;UAMW,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;;;;WAIb,eAAA,EAAiB,yBAAA;;;;WAIjB,IAAA,EAAM,IAAA;;;;WAIN,MAAA,WAAiB,iBAAA;;;;WAIjB,IAAA,EAAM,cAAA;;;;WAIN,OAAA,EAAS,iBAAA;;;;;;WAMT,KAAA,EAAO,MAAA;;;;EAIhB,KAAA,IAAS,OAAA;;;;EAIT,KAAA,IAAS,OAAA;;;;EAIT,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,gBAAA;;;;EAIX,MAAA,kBAAwB,SAAA,6BAAsC,SAAA,cAC5D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,UAAA,CAAW,MAAA,IACnB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;;;;EAIrC,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;;;;EAIrF,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EJtTnB;;;EI0TnC,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA0NnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC/lBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;;cAK1B,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;AdPU;;KcYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}

+1

-1

dist/index.d.mts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"index.d.mts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime/lease-timing.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;;UCa5C,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;;iBAMpB,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;;;ADtB7E;UEHiB,WAAA;;;;WAIN,mBAAA;EFDmC;;AAAe;EAAf,SEKnC,eAAe;AAAA;;;;;;aCHd,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;;AHT2D;aGejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EFba;AAAA;AAMpC;;EANoC,SEkBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;;AJCxB;;UIIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;;AJPkD;;KIajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;;AHXY;AAMpC;KGWY,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;;KAMH,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;;KAKhB,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCrC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;;ALhBxF;;UKuBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;;AJnCiB;AAMpC;;;;;UIuCiB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;;;;iBAkH7B,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cC9LZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;ANJzC;;;AAAA,KMWY,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;;ANpBwD;UOuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;;APhDzD;UQ2BiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;;AR9B8B;UQoC5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;AAAA;;;;KAMP,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;;cAQ5B,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;cCapB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAmBzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;AN/E9B;AAMZ;;AANY,KMiGA,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;;KAQ/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAY9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;ALhJR;KKuJlB,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;ALlI5C;;;AAAA,KK0IY,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;AT5L9C;;;AAAA,UU2DiB,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAahD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,EAAU,IAAA;EAAA;EAAA,SAEZ,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC5EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAA;EAAA,SACzB,WAAA;EV1BiB;;AAAQ;EAAR,SU8BjB,aAAA,IAAiB,GAAA,EAAK,SAAA,KAAc,SAAA;AAAA;;;;;;;UAS9B,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;AT5D7B;;;;AAQ0B;;AAR1B,USqEiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;;;UAKjD,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCwDJ,2BAAA,EAA2B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cA0B3B,sBAAA,EAAsB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cAWtB,yBAAA,EAAyB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAkCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,2BAAA;;;;KAKnC,aAAA,GAAgB,CAAA,CAAE,KAAK,QAAQ,sBAAA;;;;KAK/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,KAO9C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,UAAA,gBAA0B,SAAA,kCAA2C,MAAA,IACrE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,aAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,aAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;;UAMW,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;;;AH5NxB;WGgOW,eAAA,EAAiB,yBAAA;;;;WAIjB,IAAA,EAAM,IAAA;;;;WAIN,MAAA,WAAiB,iBAAA;;;;WAIjB,IAAA,EAAM,cAAA;;;;;;WAMN,KAAA,EAAO,MAAA;;;;EAIhB,KAAA,IAAS,OAAA;;;;EAIT,KAAA,IAAS,OAAA;;;;EAIT,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,gBAAA;;;;EAIX,MAAA,kBAAwB,SAAA,6BAAsC,SAAA,cAC5D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,UAAA,CAAW,MAAA,IACnB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;;;;EAIrC,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;;;;EAIrF,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;;;;EAItD,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA0NnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC7jBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;;cAK1B,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;AbPU;;KaYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}
		{"version":3,"file":"index.d.mts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime/lease-timing.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/signals-api.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;;UCe5C,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;;iBAMpB,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;;;ADxB7E;UEHiB,WAAA;;;;WAIN,mBAAA;EFDmC;;AAAe;EAAf,SEKnC,eAAe;AAAA;;;;;;aCHd,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;;AHT2D;aGejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EFXa;AAAA;AAMpC;;EANoC,SEgBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;;AJCxB;;UIIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;;AJPkD;;KIajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;;AHTY;AAMpC;KGSY,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;;KAMH,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;;KAKhB,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCnC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;;ALlBxF;;UKyBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,kBAAA,GAAqB,cAAA;EAAA,SACrB,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;AJpCiB;AAMpC;;;;;;AANoC,UI8CnB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,kBAAA,GAAqB,cAAA;EAAA,SACrB,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;AF1DpC;AAMT;;AANS,iBE2KO,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cCjMZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;ANJzC;;;AAAA,KMWY,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;;ANpBwD;UOuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;;APhDzD;UQqCiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;;ARxC8B;UQ8C5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;EAAA,SACR,iBAAA,WAA4B,SAAA;AAAA;;;;KAM3B,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;APvCL;cO+CvB,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;;cCEpB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAmBzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;AN/E9B;AAMZ;;AANY,KMiGA,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;;KAQ/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAY9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;ALhJR;KKuJlB,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;ALlI5C;;;AAAA,KK0IY,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;cC3KxC,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;AVjBhC;;KU0BY,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;UAK9B,iBAAA;EACf,IAAA,CAAK,SAAA,EAAW,cAAA,EAAgB,OAAA,GAAU,iBAAA,GAAoB,OAAA,UAAiB,SAAA;AAAA;;;;AVhCjF;;UW8DiB,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAWhD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,MAAA,GAAS,SAAA;EAAA,SACT,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,GAAW,IAAA;IAAA,SACX,IAAA,GAAO,wBAAA;EAAA;EAAA,SAET,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC/EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAA;EAAA,SACzB,WAAA;EXxBiB;;AAAQ;EAAR,SW4BjB,aAAA,IAAiB,GAAA,EAAK,SAAA,KAAc,SAAA;AAAA;;;;;;;UAS9B,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;AV5D7B;;;;AAQ0B;;AAR1B,UUqEiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;;;UAKjD,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCuGJ,sBAAA,EAAsB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cActB,yBAAA,EAAyB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAwB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,yBAAyB;;;;KAK7C,aAAA,GAAgB,CAAA,CAAE,KAAK,QAAQ,sBAAA;AJzN3C;;;AAAA,KI8NY,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,KAO9C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,UAAA,gBAA0B,SAAA,kCAA2C,MAAA,IACrE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,aAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,aAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;;UAMW,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;;;;WAIb,eAAA,EAAiB,yBAAA;;;;WAIjB,IAAA,EAAM,IAAA;;;;WAIN,MAAA,WAAiB,iBAAA;;;;WAIjB,IAAA,EAAM,cAAA;;;;WAIN,OAAA,EAAS,iBAAA;;;;;;WAMT,KAAA,EAAO,MAAA;;;;EAIhB,KAAA,IAAS,OAAA;;;;EAIT,KAAA,IAAS,OAAA;;;;EAIT,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,gBAAA;;;;EAIX,MAAA,kBAAwB,SAAA,6BAAsC,SAAA,cAC5D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,UAAA,CAAW,MAAA,IACnB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;;;;EAIrC,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;;;;EAIrF,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EJtTnB;;;EI0TnC,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA0NnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC/lBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;;cAK1B,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;AdPU;;KcYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}

+5

-5

package.json

		{
		"name": "@runlane/core",
		"version": "0.2.0",
		"version": "0.3.0",
		"description": "Runlane's durable task runtime: triggers, workers, schedules, retries, idempotency, leases, and operator APIs.",
		@@ -54,4 +54,4 @@ "type": "module",
		"zod": "^4.3.6",
		"@runlane/contracts": "0.2.0",
		"@runlane/utilities": "0.2.0"
		"@runlane/contracts": "0.3.0",
		"@runlane/utilities": "0.3.0"
		},
		@@ -63,4 +63,4 @@ "devDependencies": {
		"@repo/vitest": "0.0.0",
		"@runlane/local-adapters": "0.2.0",
		"@runlane/testing": "0.2.0"
		"@runlane/local-adapters": "0.3.0",
		"@runlane/testing": "0.3.0"
		},
		@@ -67,0 +67,0 @@ "scripts": {

dist/index.cjs