Add Limit node to pframe QuerySpec/QueryData

.changeset/ecr-login-lock.md

@@ -0,0 +1,6 @@
+---
+"@platforma-sdk/block-tools": patch
+---
+
+Fix concurrent `docker login` race during parallel software builds: serialize the ECR login
+across processes with a cross-process file lock, avoiding the macOS keychain -25299 error.

.changeset/three-pants-mix.md

@@ -0,0 +1,9 @@
+---
+"@milaboratories/pl-model-common": patch
+"@milaboratories/pf-spec-driver": patch
+"@milaboratories/pf-driver": patch
+"@platforma-sdk/model": patch
+---
+
+PFrames update: add Limit query node. createPlDataTableV3 caps results at 50k
+rows when the runtime supports the pFrameQueryLimitSupport feature flag.

lib/model/common/src/drivers/pframe/query/query_common.ts

@@ -918,6 +918,29 @@ export interface QueryFilter<Q, E> {
   predicate: E;
 }
 
+/**
+ * Limit query operation.
+ *
+ * Keeps only the first `fetch` records.
+ *
+ * **Behavior**:
+ * - All axes and columns pass through unchanged; only record count changes
+ * - Order is determined by the pending sort of the input (or axis order by default)
+ *
+ * @template Q - Input query type
+ *
+ * @example
+ * // Keep the first 100 records
+ * { type: 'limit', input: dataQuery, fetch: 100 }
+ */
+export interface QueryLimit<Q> {
+  type: "limit";
+  /** Input query to limit */
+  input: Q;
+  /** Maximum number of records to keep */
+  fetch: number;
+}
+
 /**
  * Column reference query (leaf node).
  *

lib/model/common/src/drivers/pframe/query/query_data.ts

@@ -23,6 +23,7 @@ import type {
   QueryFilter,
   QueryInlineColumn,
   QueryJoinEntry,
+  QueryLimit,
   QueryLinkerJoin,
   QueryOuterJoin,
   QuerySliceAxes,
@@ -101,6 +102,8 @@ export type DataQuerySliceAxes = QuerySliceAxes<DataQuery, number>;
 export type DataQuerySort = QuerySort<DataQuery, DataQueryExpression>;
 /** @see QueryFilter */
 export type DataQueryFilter = QueryFilter<DataQuery, DataQueryBooleanExpression>;
+/** @see QueryLimit */
+export type DataQueryLimit = QueryLimit<DataQuery>;
 /** @see QueryTransformColumns */
 export type DataQueryTransformColumns = QueryTransformColumns<
   DataQuery,
@@ -129,6 +132,7 @@ export type DataQuery =
   | DataQuerySliceAxes
   | DataQuerySort
   | DataQueryFilter
+  | DataQueryLimit
   | DataQueryTransformColumns;
 
 /** @see ExprAxisRef */

lib/model/common/src/drivers/pframe/query/query_spec.ts

@@ -24,6 +24,7 @@ import type {
   QueryFilter,
   QueryInlineColumn,
   QueryJoinEntry,
+  QueryLimit,
   QueryLinkerJoin,
   QueryOuterJoin,
   QuerySliceAxes,
@@ -88,6 +89,8 @@ export type SpecQueryFilter<C = ColumnUniversalId> = QueryFilter<
   SpecQuery<C>,
   SpecQueryBooleanExpression
 >;
+/** @see QueryLimit */
+export type SpecQueryLimit<C = ColumnUniversalId> = QueryLimit<SpecQuery<C>>;
 /** @see QueryTransformColumns */
 export type SpecQueryTransformColumns<C = ColumnUniversalId> = QueryTransformColumns<
   SpecQuery<C>,
@@ -131,6 +134,7 @@ export type SpecQuery<C = ColumnUniversalId> =
   | SpecQuerySliceAxes<C>
   | SpecQuerySort<C>
   | SpecQueryFilter<C>
+  | SpecQueryLimit<C>
   | SpecQueryTransformColumns<C>
   | SpecQuerySpecOverride<C>;
 

lib/model/common/src/drivers/pframe/query/utils.ts

@@ -95,6 +95,7 @@ export function traverseQuerySpec<C1, C2>(
     }
     case "filter":
     case "sort":
+    case "limit":
     case "sliceAxes":
     case "transformColumns":
     case "specOverride":
@@ -259,6 +260,12 @@ function cmpQuerySpec(lhs: SpecQuery, rhs: SpecQuery): number {
       return cmpQuerySpec(lhs.input, (rhs as typeof lhs).input);
     case "filter":
       return cmpQuerySpec(lhs.input, (rhs as typeof lhs).input);
+    case "limit": {
+      const rhsLimit = rhs as typeof lhs;
+      const cmp = cmpQuerySpec(lhs.input, rhsLimit.input);
+      if (cmp !== 0) return cmp;
+      return lhs.fetch - rhsLimit.fetch;
+    }
     case "specOverride": {
       const rhsSo = rhs as typeof lhs;
       const cmp = cmpQuerySpec(lhs.input, rhsSo.input);