fix file naming

Author: jamesamcl

main.nf

@@ -240,11 +240,11 @@ process join_embeddings {
   publishDir "${params.out}", overwrite: true
 
   input:
-  tuple val(model), path(prev_pq), path(new_pq)
+  tuple val(model), path(prev_pq, stageAs: 'prev.parquet'), path(new_pq)
   path terms_tsv
 
   output:
-  tuple val(model), path("${model.split('/')[1]}_joined.parquet")
+  tuple val(model), path("${model.split('/')[1]}.parquet")
 
   script:
   def model_short = model.split('/')[1]
@@ -266,7 +266,7 @@ process join_embeddings {
         NULL::FLOAT[]  AS embedding
       WHERE FALSE
       """
-    : "SELECT * FROM read_parquet('${prev_pq.toString()}')"
+    : "SELECT * FROM read_parquet('prev.parquet')"
 
   """
   duckdb /dev/shm/terms_embedded.duckdb -c "
@@ -333,7 +333,7 @@ process join_embeddings {
       UNION ALL
       SELECT * FROM carryover
     )
-    TO '${model_short}_joined.parquet'
+    TO '${model_short}.parquet'
     (FORMAT PARQUET, COMPRESSION ZSTD);
   "
   """