Try this

sql/stats.prql

@@ -91,15 +91,12 @@ let stats_over_time = (
       total_size = sum(size) | as bigint,
       total_lines = sum(lines) | as bigint,
       total_hours = s"date_diff('hours', min({uploaded_on}), max({uploaded_on}))",
-      lines_per_hour = total_lines / total_hours | as bigint,
-      bytes_per_hour = total_size / total_hours | as bigint,
-      files_per_hour = total_files / total_hours | as bigint,
-      releases_per_hour = total_uploads / total_hours | as bigint,
     }
   )
 )
 
 
+
 relation_to_json(total_stats)
 append (relation_to_json extension_stats)
 append (relation_to_json binary_extension_stats)

src/pypi_data/cli.py

@@ -94,10 +94,9 @@ def run_sql(
         sql = prql_file.read_text()
         # Can't get it to work without doing this. So dumb.
         compiled_sql = sql.replace('$1', json.dumps(parameter))
-        # sql = f"{sql}; COPY temp_table TO '{output_file}' (FORMAT PARQUET, COMPRESSION zstd);"
-        parameter = []
     else:
-        compiled_sql = prql.compile(prql_file.read_text(), options=options)
+        # to-do: make this not shit....
+        compiled_sql = prql.compile(prql_file.read_text(), options=options).replace('$1', json.dumps(parameter))
     sql = f"CREATE TABLE temp_table AS {compiled_sql}; COPY temp_table TO '{output_file}' (FORMAT PARQUET, COMPRESSION zstd)"
     print(sql)
 
@@ -124,8 +123,7 @@ def print_thread():
     con.executemany(f"PRAGMA threads=4; "
                        f"PRAGMA memory_limit='2GB'; "
                        # f"PRAGMA enable_profiling;"
-                       f"{sql}",
-                       parameters=[[parameter]] if parameter else [])
+                       f"{sql}")
     try:
         for name, plan in con.fetchall():
             print(name)