wip

model/src/index.ts

@@ -15,30 +15,30 @@ export const platforma = BlockModel.create<BlockArgs>('Heavy')
     ctx.precalc?.resolve({ field: 'presets', assertFieldType: 'Input' })?.getFileHandle()
   )
 
-  .output('inputOptions', (ctx) =>
-    ctx.resultPool
-      .getSpecsFromResultPool()
-      .entries.filter((v) => {
-        if (!isPColumnSpec(v.obj)) return false;
-        const domain = v.obj.domain;
-        return (
-          v.obj.name === 'pl7.app/data/sequencing' &&
-          ((v.obj.valueType as string) === 'blob' || (v.obj.valueType as string) === 'file') &&
-          domain !== undefined &&
-          (domain['pl7.app/fileExtension'] === 'fastq' ||
-            domain['pl7.app/fileExtension'] === 'fastq.gz')
-        );
-      })
-      .map(
-        (v) =>
-          ({
-            ref: v.ref,
-            label: `${ctx.getBlockLabel(v.ref.blockId)} / ${
-              v.obj.annotations?.['pl7.app/label'] ?? `unlabelled`
-            }`
-          } satisfies Option)
-      )
-  )
+  .output('inputOptions', (ctx) => [])
+  //   ctx.resultPool
+  //     .getSpecsFromResultPool()
+  //     .entries.filter((v) => {
+  //       if (!isPColumnSpec(v.obj)) return false;
+  //       const domain = v.obj.domain;
+  //       return (
+  //         v.obj.name === 'pl7.app/data/sequencing' &&
+  //         ((v.obj.valueType as string) === 'blob' || (v.obj.valueType as string) === 'file') &&
+  //         domain !== undefined &&
+  //         (domain['pl7.app/fileExtension'] === 'fastq' ||
+  //           domain['pl7.app/fileExtension'] === 'fastq.gz')
+  //       );
+  //     })
+  //     .map(
+  //       (v) =>
+  //         ({
+  //           ref: v.ref,
+  //           label: `${ctx.getBlockLabel(v.ref.blockId)} / ${
+  //             v.obj.annotations?.['pl7.app/label'] ?? `unlabelled`
+  //           }`
+  //         } satisfies Option)
+  //     )
+  // )
 
   .sections((ctx) => {
     return [{ type: 'link', href: '/', label: 'Settings' }];

package.json

@@ -44,7 +44,7 @@
   },
   "pnpm": {
     "overrides": {
-      "@milaboratory/pl-middle-layer": "file:/Volumes/Data/Projects/MiLaboratory/platforma/ts-pl-middle-layer/milaboratory-pl-middle-layer-1.9.27.tgz"
+      "@milaboratory/pl-middle-layer": "file:/Volumes/Data/Projects/MiLaboratory/platforma/ts-pl-middle-layer/milaboratory-pl-middle-layer-1.9.29.tgz"
     }
   }
 }

pnpm-workspace.yaml

@@ -11,9 +11,9 @@ catalog:
   '@milaboratory/block-builder': ^1.2.3
 
   '@milaboratory/sdk-ui': ^0.12.18
-  '@milaboratory/sdk-test': ^1.4.8
+  '@milaboratory/sdk-test': ^1.4.9
 
-  '@milaboratory/tengo-sdk': ^1.0.8
+  '@milaboratory/tengo-sdk': ^1.0.9
 
   '@milaboratory/platforma-uikit': ^1.0.24
   '@milaboratory/sdk-vue': ^1.0.33

test/src/wf.test.ts

@@ -8,6 +8,7 @@ import { blockSpec as samplesAndDataBlockSpec } from '@milaboratory/milaboratori
 import { BlockArgs as SamplesAndDataBlockArgs } from '@milaboratory/milaboratories.samples-and-data.model';
 import { blockSpec as myBlockSpec } from 'this-block';
 import { wrapOutputs } from '@milaboratory/sdk-ui';
+import * as tp  from 'node:timers/promises';
 
 blockTest('empty imputs', { timeout: 5000 }, async ({ rawPrj: project, ml, helpers, expect }) => {
   const blockId = await project.addBlock('Block', myBlockSpec);
@@ -22,7 +23,7 @@ blockTest('empty imputs', { timeout: 5000 }, async ({ rawPrj: project, ml, helpe
     await ml.driverKit.blobDriver.getContent(presetsOutput!.handle)
   ).toString();
   const presets = JSON.parse(presetsStr);
-  console.dir(presets, { depth: 5 });
+  expect(presets).length.gt(10);
 });
 
 blockTest(
@@ -82,6 +83,9 @@ blockTest(
       fileImports: { ok: true, value: { [r1Handle]: { done: true }, [r2Handle]: { done: true } } }
     });
 
+    console.dir(await clonotypingBlockState.getFullValue(), { depth: 5 });
+    await tp.setTimeout(2000);
+    console.dir(await clonotypingBlockState.getFullValue(), { depth: 5 });
     const clonotypingStableState1 = await awaitStableState(clonotypingBlockState, 5000);
     expect(clonotypingStableState1.outputs).toMatchObject({
       inputOptions: {

workflow/src/prerun.tpl.tengo

@@ -8,8 +8,8 @@ wf.body(func(args) {
 						cmd("mixcr").
 						arg("listPresetSpecificationsForUI").
 						arg("presets.json").
-						saveFile("presets.json").
 						cache(24 * 60 * 60 * 1000).
+						saveFile("presets.json").
 						run()
 
 	return {