import{S as qe,i as Fe,s as Re,e as le,b as U,$ as ke,h as E,D as ce,E as Y,F as Ve,Q as w,k as L,l as B,m as G,I as W,H as _,K as A,O as he,P as ge,a1 as We,p as Ee,g as M,v as Qe,d as O,f as je,C as Xe,o as Ze,G as ie,y as Le,a as x,z as Be,c as $,J as F,A as Ge,L as se,M as ae,N as oe,B as Ke,q as Ue,r as ze,u as He}from"./index.2add268f.js";import{N as xe,a as $e,r as D,O as P,i as et,j as De,k as tt,l as nt,p as it,m as st,f as C,g as fe,b as K,n as at,T as ot,w as rt}from"./taskMonitoringStore.5b185d7a.js";function Pe(t,e,n){const i=t.slice();return i[2]=e[n].width,i}function lt(t){let e,n,i,a,s=[t[4],{style:n="width: "+t[2]+";"+t[4].style}],c={};for(let u=0;u{e=Y(Y({},e),Ve(d)),n(4,u=ce(e,c)),"lines"in d&&n(5,r=d.lines),"heading"in d&&n(0,h=d.heading),"paragraph"in d&&n(1,f=d.paragraph),"width"in d&&n(2,y=d.width)},t.$$.update=()=>{if(t.$$.dirty&4&&n(7,a=parseInt(y,10)),t.$$.dirty&4&&n(6,s=y.includes("px")),t.$$.dirty&238&&f)for(let d=0;d({}),we=t=>({}),mt=t=>({}),Me=t=>({}),ht=t=>({}),Ae=t=>({});function Ie(t){let e,n,i,a,s,c,u,r,h,f,y,g,I,N;i=new xe({props:{notificationType:"inline",kind:t[0],iconDescription:t[6]}});const R=t[13].title,V=ie(R,t,t[12],Ae),v=V||gt(t),Q=t[13].subtitle,q=ie(Q,t,t[12],Me),k=q||pt(t),d=t[13].default,S=ie(d,t,t[12],null),z=t[13].actions,l=ie(z,t,t[12],we);let p=!t[5]&&Ne(t),de=[{role:t[2]},{kind:t[0]},t[10]],ne={};for(let o=0;o{p=null}),je()):p?(p.p(o,m),m&32&&M(p,1)):(p=Ne(o),p.c(),M(p,1),p.m(e,null)),W(e,ne=he(de,[(!g||m&4)&&{role:o[2]},(!g||m&1)&&{kind:o[0]},m&1024&&o[10]])),_(e,"bx--inline-notification",!0),_(e,"bx--inline-notification--low-contrast",o[1]),_(e,"bx--inline-notification--hide-close-button",o[5]),_(e,"bx--inline-notification--error",o[0]==="error"),_(e,"bx--inline-notification--info",o[0]==="info"),_(e,"bx--inline-notification--info-square",o[0]==="info-square"),_(e,"bx--inline-notification--success",o[0]==="success"),_(e,"bx--inline-notification--warning",o[0]==="warning"),_(e,"bx--inline-notification--warning-alt",o[0]==="warning-alt")},i(o){g||(M(i.$$.fragment,o),M(v,o),M(k,o),M(S,o),M(l,o),M(p),g=!0)},o(o){O(i.$$.fragment,o),O(v,o),O(k,o),O(S,o),O(l,o),O(p),g=!1},d(o){o&&E(e),Ke(i),v&&v.d(o),k&&k.d(o),S&&S.d(o),l&&l.d(o),p&&p.d(),I=!1,ge(N)}}}function gt(t){let e;return{c(){e=Ue(t[3])},l(n){e=ze(n,t[3])},m(n,i){U(n,e,i)},p(n,i){i&8&&He(e,n[3])},d(n){n&&E(e)}}}function pt(t){let e;return{c(){e=Ue(t[4])},l(n){e=ze(n,t[4])},m(n,i){U(n,e,i)},p(n,i){i&16&&He(e,n[4])},d(n){n&&E(e)}}}function Ne(t){let e,n;return e=new $e({props:{iconDescription:t[7],notificationType:"inline"}}),e.$on("click",t[9]),{c(){Le(e.$$.fragment)},l(i){Be(e.$$.fragment,i)},m(i,a){Ge(e,i,a),n=!0},p(i,a){const s={};a&128&&(s.iconDescription=i[7]),e.$set(s)},i(i){n||(M(e.$$.fragment,i),n=!0)},o(i){O(e.$$.fragment,i),n=!1},d(i){Ke(e,i)}}}function bt(t){let e,n,i=t[8]&&Ie(t);return{c(){i&&i.c(),e=le()},l(a){i&&i.l(a),e=le()},m(a,s){i&&i.m(a,s),U(a,e,s),n=!0},p(a,[s]){a[8]?i?(i.p(a,s),s&256&&M(i,1)):(i=Ie(a),i.c(),M(i,1),i.m(e.parentNode,e)):i&&(Qe(),O(i,1,1,()=>{i=null}),je())},i(a){n||(M(i),n=!0)},o(a){O(i),n=!1},d(a){i&&i.d(a),a&&E(e)}}}function yt(t,e,n){const i=["kind","lowContrast","timeout","role","title","subtitle","hideCloseButton","statusIconDescription","closeButtonDescription"];let a=ce(e,i),{$$slots:s={},$$scope:c}=e,{kind:u="error"}=e,{lowContrast:r=!1}=e,{timeout:h=0}=e,{role:f="alert"}=e,{title:y=""}=e,{subtitle:g=""}=e,{hideCloseButton:I=!1}=e,{statusIconDescription:N=u+" icon"}=e,{closeButtonDescription:R="Close notification"}=e;const V=Xe();let v=!0,Q;function q(l){V("close",{timeout:l===!0},{cancelable:!0})&&n(8,v=!1)}Ze(()=>(h&&(Q=setTimeout(()=>q(!0),h)),()=>{clearTimeout(Q)}));function k(l){w.call(this,t,l)}function d(l){w.call(this,t,l)}function S(l){w.call(this,t,l)}function z(l){w.call(this,t,l)}return t.$$set=l=>{e=Y(Y({},e),Ve(l)),n(10,a=ce(e,i)),"kind"in l&&n(0,u=l.kind),"lowContrast"in l&&n(1,r=l.lowContrast),"timeout"in l&&n(11,h=l.timeout),"role"in l&&n(2,f=l.role),"title"in l&&n(3,y=l.title),"subtitle"in l&&n(4,g=l.subtitle),"hideCloseButton"in l&&n(5,I=l.hideCloseButton),"statusIconDescription"in l&&n(6,N=l.statusIconDescription),"closeButtonDescription"in l&&n(7,R=l.closeButtonDescription),"$$scope"in l&&n(12,c=l.$$scope)},[u,r,f,y,g,I,N,R,v,q,a,h,c,s,k,d,S,z]}class vt extends qe{constructor(e){super(),Fe(this,e,yt,bt,Re,{kind:0,lowContrast:1,timeout:11,role:2,title:3,subtitle:4,hideCloseButton:5,statusIconDescription:6,closeButtonDescription:7})}}const Nt=vt;class pe{static getSources(){return D(P,{method:"GET",url:"/api/v1/data_loaders/"})}static getSourceSchema(e){return D(P,{method:"GET",url:"/api/v1/data_loaders/{source_name}",path:{source_name:e},errors:{422:"Validation Error"}})}static load(e,n){return D(P,{method:"POST",url:"/api/v1/data_loaders/{source_name}/load",path:{source_name:e},body:n,mediaType:"application/json",errors:{422:"Validation Error"}})}}class T{static getDatasets(){return D(P,{method:"GET",url:"/api/v1/datasets/"})}static getManifest(e,n){return D(P,{method:"GET",url:"/api/v1/datasets/{namespace}/{dataset_name}",path:{namespace:e,dataset_name:n},errors:{422:"Validation Error"}})}static deleteDataset(e,n){return D(P,{method:"DELETE",url:"/api/v1/datasets/{namespace}/{dataset_name}",path:{namespace:e,dataset_name:n},errors:{422:"Validation Error"}})}static computeSignal(e,n,i){return D(P,{method:"POST",url:"/api/v1/datasets/{namespace}/{dataset_name}/compute_signal",path:{namespace:e,dataset_name:n},body:i,mediaType:"application/json",errors:{422:"Validation Error"}})}static deleteSignal(e,n,i){return D(P,{method:"DELETE",url:"/api/v1/datasets/{namespace}/{dataset_name}/delete_signal",path:{namespace:e,dataset_name:n},body:i,mediaType:"application/json",errors:{422:"Validation Error"}})}static getStats(e,n,i){return D(P,{method:"POST",url:"/api/v1/datasets/{namespace}/{dataset_name}/stats",path:{namespace:e,dataset_name:n},body:i,mediaType:"application/json",errors:{422:"Validation Error"}})}static selectRowsDownload(e,n,i){return D(P,{method:"GET",url:"/api/v1/datasets/{namespace}/{dataset_name}/select_rows_download",path:{namespace:e,dataset_name:n},query:{url_safe_options:i},errors:{422:"Validation Error"}})}static selectRows(e,n,i){return D(P,{method:"POST",url:"/api/v1/datasets/{namespace}/{dataset_name}/select_rows",path:{namespace:e,dataset_name:n},body:i,mediaType:"application/json",errors:{422:"Validation Error"}})}static selectRowsSchema(e,n,i){return D(P,{method:"POST",url:"/api/v1/datasets/{namespace}/{dataset_name}/select_rows_schema",path:{namespace:e,dataset_name:n},body:i,mediaType:"application/json",errors:{422:"Validation Error"}})}static selectGroups(e,n,i){return D(P,{method:"POST",url:"/api/v1/datasets/{namespace}/{dataset_name}/select_groups",path:{namespace:e,dataset_name:n},body:i,mediaType:"application/json",errors:{422:"Validation Error"}})}static getMedia(e,n,i,a){return D(P,{method:"GET",url:"/api/v1/datasets/{namespace}/{dataset_name}/media",path:{namespace:e,dataset_name:n},query:{item_id:i,leaf_path:a},errors:{422:"Validation Error"}})}}const ue="*",Ot="__rowid__",H="__value__",Ct={text:["string","string_span"],text_embedding:["embedding"],image:["binary"]};function qt(t){return St(t)||kt(t)}function St(t){return["float16","float32","float64"].indexOf(t??"")>=0}function kt(t){return["int8","int16","int32","int64","uint8","uint16","uint32","uint64"].indexOf(t)>=0}function Ft(t){return typeof t=="string"?t:t.map(e=>e.includes(".")?`"${e}"`:e).join(".")}function Rt(t){return t.dtype&&!["embedding","binary","string_span"].includes(t.dtype)}function Vt(t){return t.dtype&&!["embedding","binary"].includes(t.dtype)}function X(t){var n;return Array.isArray(t)?t:((n=t.match(/(?:"[^"]*"|[^.])+(?:\.+$)?/g))==null?void 0:n.map(i=>i.replace(/"/g,"")))||[]}function Et(t,e){if(!t||!e||(t=X(t),e=X(e),t.length!==e.length))return!1;for(let n=0;nn.path.length>0)}function Gt(t){return t==null?[]:Z(t).filter(e=>e.dtype!=null)}function Kt(t,e){return e==null?[]:(e?Z(e):[]).filter(i=>i.dtype==t)}function re(t){let e;if(Array.isArray(t))e=[...t,...t.flatMap(re)];else{const{[H]:n,[ee]:i,[te]:a,...s}=t,c=Object.values(s||{});e=[];for(const u of c)if(Array.isArray(u)){e=[...e,u];for(const r of u)e=[...e,r,...re(r)]}else e=[...e,u,...re(u)]}return e}function Ut(t,e){return Z(t).find(i=>be(i.path,e))}function zt(t,e){return re(t).filter(i=>be(e,Je.path(i)))}function Oe(t,e,n=!1){return Pt(e)&&(n=!0),e===t?n:e.fields!=null?Object.values(e.fields).some(i=>Oe(t,i,n)):e.repeated_field!=null?Oe(t,e.repeated_field,n):!1}function Pt(t){return t.signal!=null}const Je={path:t=>{if(!t)return;const e=t[ee];if(e==null)throw Error(`Item does not have a path defined: ${JSON.stringify(t)}`);return e},value:(t,e)=>t?t[H]:null,field:t=>{if(t)return t[te]},dtype:t=>{const e=Je.field(t);return e==null?void 0:e.dtype}};function _e(t,e){const{fields:n,repeated_field:i,...a}=t,s={...a,path:[]};if(n!=null){s.fields={};for(const[c,u]of Object.entries(n)){const r=_e(u,[...e,c]);r.path=[...e,c],s.fields[c]=r}}if(i!=null){const c=_e(i,[...e,ue]);c.path=[...e,ue],s.repeated_field=c}return s}function me(t,e,n){const i=e.find(s=>be(s.path,n));let a={};if(Array.isArray(t))return a=t.map((s,c)=>me(s,e,[...n,c.toString()])),a[H]=null,a[ee]=n,a[te]=i,a;if(t!=null&&typeof t=="object"){const{[H]:s,...c}=t;a=Object.entries(c).reduce((u,[r,h])=>(u[r]=me(h,e,[...n,r]),u),{}),a[H]=s}else a[H]=t;return a[ee]=n,a[te]=i,a}class Tt extends et{constructor(e,n){super(e,n)}bindMethods(){super.bindMethods(),this.fetchNextPage=this.fetchNextPage.bind(this),this.fetchPreviousPage=this.fetchPreviousPage.bind(this)}setOptions(e,n){super.setOptions({...e,behavior:De()},n)}getOptimisticResult(e){return e.behavior=De(),super.getOptimisticResult(e)}fetchNextPage({pageParam:e,...n}={}){return this.fetch({...n,meta:{fetchMore:{direction:"forward",pageParam:e}}})}fetchPreviousPage({pageParam:e,...n}={}){return this.fetch({...n,meta:{fetchMore:{direction:"backward",pageParam:e}}})}createResult(e,n){var i,a,s,c,u,r;const{state:h}=e,f=super.createResult(e,n),{isFetching:y,isRefetching:g}=f,I=y&&((i=h.fetchMeta)==null||(a=i.fetchMore)==null?void 0:a.direction)==="forward",N=y&&((s=h.fetchMeta)==null||(c=s.fetchMore)==null?void 0:c.direction)==="backward";return{...f,fetchNextPage:this.fetchNextPage,fetchPreviousPage:this.fetchPreviousPage,hasNextPage:tt(n,(u=h.data)==null?void 0:u.pages),hasPreviousPage:nt(n,(r=h.data)==null?void 0:r.pages),isFetchingNextPage:I,isFetchingPreviousPage:N,isRefetching:g&&!I&&!N}}}function wt(t,e,n){const i=it(t,e,n);return st(i,Tt)}const b="datasets",Ce=20,Ht=C(T.getDatasets,b),Yt=C(T.getManifest,b,{}),Jt=C(T.getManifest,b,{select:t=>ye(t.dataset_manifest.data_schema)}),Wt=C(function(e,n){return e&&n?T.getManifest(e,n):Promise.resolve(null)},b,{select:t=>t?ye(t.dataset_manifest.data_schema):null}),Xt=C(pe.getSources,b),Zt=C(pe.getSourceSchema,b,{select:t=>t}),xt=fe(pe.load),$t=fe(T.computeSignal,{onSuccess:t=>{K.invalidateQueries([ot]),rt(t.task_id,()=>{K.invalidateQueries([b,"getManifest"]),K.invalidateQueries([b,"selectRowsSchema"]),K.invalidateQueries([b,"selectRows"])})}}),en=fe(T.deleteDataset,{onSuccess:()=>{K.invalidateQueries([b])}}),tn=fe(T.deleteSignal,{onSuccess:()=>{K.invalidateQueries([b,"getManifest"]),K.invalidateQueries([b,"selectRowsSchema"]),K.invalidateQueries([b,"selectRows"])}}),nn=C(T.getStats,b),sn=at(T.getStats,b),an=C(async function(e,n,i,a){const s=await T.selectRows(e,n,i);return{rows:s.rows.map(c=>Ye(c,a)),total_num_rows:s.total_num_rows}},b),on=C(T.selectRowsSchema,b,{select:t=>({schema:ye(t.data_schema),...t})}),rn=C(T.selectGroups,b),ln=(t,e,n,i)=>wt({queryKey:[b,"selectRows",t,e,n],queryFn:({pageParam:a=0})=>T.selectRows(t,e,{...n,limit:n.limit||Ce,offset:a*(n.limit||Ce)}),select:a=>({...a,pages:a.pages.map(s=>({rows:s.rows.map(c=>Ye(c,i)),total_num_rows:s.total_num_rows}))}),getNextPageParam:(a,s)=>s.length,enabled:!!i});function cn(t){return t!=null}function un(t,e){return`/concepts#!/${t}/${e}`}function fn(t,e){return`/datasets#!/${t}/${e}`}export{Ut as A,Kt as B,sn as C,on as D,b as E,Bt as F,Ct as G,be as H,Nt as I,qt as J,Dt as K,Je as L,ye as M,Ye as N,an as O,ue as P,Wt as Q,Xt as R,It as S,xt as T,Ot as U,H as V,Zt as W,fn as a,X as b,un as c,en as d,Z as e,Lt as f,Qt as g,zt as h,jt as i,Pt as j,$t as k,re as l,Gt as m,cn as n,Yt as o,Et as p,Ht as q,Jt as r,Ft as s,ln as t,tn as u,Oe as v,Rt as w,Vt as x,nn as y,rn as z};