fixed experiment duration and removed unsused env vars

.env

@@ -3,18 +3,11 @@ PGUSER=postgres
 PGDATABASE=postgres
 PGHOST=postgres
 
-# sub
+# pg_inserter
+BATCH_SIZE=10000
 EDGE_INSERTS=EDGE_INSERTS
 UUID_EDGES=
 
-# pub-sub
-MOS_HOST=mosquitto
-MOS_TOPIC=ta1-cadets-e3-official
-
-# pub
-LINES_PER_SECOND=10000
-BATCH_SIZE=10000
-
 # query
 QUERY_INTERVAL=1
 

query/cdm_sql_queries.py

@@ -55,7 +55,7 @@ if __name__ == "__main__":
         csv.writer(file).writerow(("TIMESTAMP", "VERTEX_COUNT"))
 
     info("Starting...")
-    end_time = timedelta(seconds=20)
+    end_time = timedelta(hours=1)
     schedule.every(5).seconds.until(end_time).do(perf_job, csv_path)
     while (sleep_time := schedule.idle_seconds()) is not None and not interrupted:
         sleep(max(sleep_time, 0))