fixes

ArroyoSystems · Jun 21, 2024 · b056cad · b056cad
1 parent d2d1a5d
commit b056cad
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 10 deletions.
diff --git a/crates/arroyo-api/src/udfs.rs b/crates/arroyo-api/src/udfs.rs
@@ -81,8 +81,8 @@ pub async fn create_udf(
     api_queries::execute_create_udf(
         &client,
         &pub_id,
-        &auth_data.user_id,
         &auth_data.organization_id,
+        &auth_data.user_id,
         &req.prefix,
         &udf_name,
         &req.definition,

diff --git a/webui/src/lib/data_fetching.ts b/webui/src/lib/data_fetching.ts
@@ -217,12 +217,11 @@ const connectionTablesFetcher = () => {
   };
 };
 
-export const useConnectionTables = (limit: number) => {
+export const useConnectionTables = (limit: number, refresh?: boolean) => {
+  const options = refresh ? { refreshInterval: 5000 } : {};
   const { data, isLoading, mutate, size, setSize } = useSWRInfinite<
     schemas['ConnectionTableCollection']
-  >(connectionTablesKey(limit), connectionTablesFetcher(), {
-    refreshInterval: 5000,
-  });
+  >(connectionTablesKey(limit), connectionTablesFetcher(), options);
 
   return {
     connectionTablePages: data,

diff --git a/webui/src/routes/pipelines/CatalogTab.tsx b/webui/src/routes/pipelines/CatalogTab.tsx
@@ -5,7 +5,7 @@ import { ConnectionTable, useConnectionTables } from '../../lib/data_fetching';
 import { Catalog } from './Catalog';
 
 const CatalogTab: React.FC = () => {
-  const { connectionTablePages, connectionTablesLoading } = useConnectionTables(200);
+  const { connectionTablePages, connectionTablesLoading } = useConnectionTables(200, false);
 
   let connectionTables: ConnectionTable[] = [];
   let catalogTruncated = false;

diff --git a/webui/src/routes/pipelines/CreatePipeline.tsx b/webui/src/routes/pipelines/CreatePipeline.tsx
@@ -81,13 +81,11 @@ export function CreatePipeline() {
   const [operatorErrors, setOperatorErrors] = useState<JobLogMessage[]>([]);
   const [queryInput, setQueryInput] = useState<string>('');
   const [queryInputToCheck, setQueryInputToCheck] = useState<string | undefined>(undefined);
-  const { operatorMetricGroups } = useJobMetrics(pipelineId, job?.id);
   const { isOpen, onOpen, onClose } = useDisclosure();
   const [options, setOptions] = useState<SqlOptions>({ parallelism: 4, checkpointMS: 5000 });
   const navigate = useNavigate();
   const [startError, setStartError] = useState<string | null>(null);
   const [tabIndex, setTabIndex] = useState<number>(0);
-  const { connectionTablesLoading } = useConnectionTables(50);
   const queryParams = useQuery();
   const { pipeline: copyFrom, pipelineLoading: copyFromLoading } = usePipeline(
     queryParams.get('from') ?? undefined
@@ -213,7 +211,7 @@ export function CreatePipeline() {
   }, [sidebarElement]);
 
   // Top-level loading state
-  if (copyFromLoading || connectionTablesLoading || !localUdfs) {
+  if (copyFromLoading || !localUdfs) {
     return <Loading />;
   }
 
@@ -388,7 +386,6 @@ export function CreatePipeline() {
         >
           <PipelineGraphViewer
             graph={queryValidation.graph}
-            operatorMetricGroups={operatorMetricGroups}
             setActiveOperator={() => {}}
           />
         </Box>