temp: fix schema

Author: NathanFlurry

packages/core/api/actor/src/route/logs.rs

@@ -297,6 +297,7 @@ pub async fn export_logs(
 		presigned_endpoint_kind: Some(backend::pkg::upload::prepare::EndpointKind::Internal as i32),
 	})
 	.await?;
+	let upload_id = unwrap!(upload_res.upload_id).as_uuid();
 
 	let presigned_req = unwrap!(upload_res.presigned_requests.first());
 
@@ -332,7 +333,7 @@ pub async fn export_logs(
 	let presigned_req = s3_client
 		.get_object()
 		.bucket(s3_client.bucket())
-		.key(filename)
+		.key(format!("{upload_id}/{filename}"))
 		.presigned(
 			s3_util::aws_sdk_s3::presigning::PresigningConfig::builder()
 				.expires_in(Duration::from_secs(60 * 60))

packages/edge/services/pegboard/db/actor-log/migrations/20250703195340_fix_actor_logs3_metadata.up.sql

@@ -32,5 +32,5 @@ AS SELECT
     a.client_id,
 	a.durable
 FROM actor_logs3 l
-LEFT JOIN db_pegboard_analytics.actors a ON l.namespace = a.namespace AND l.env_id = a.env_id AND l.actor_id = a.actor_id;
+ANY LEFT JOIN db_pegboard_analytics.actors a ON l.namespace = a.namespace AND l.env_id = a.env_id AND l.actor_id = a.actor_id;
 

packages/edge/services/pegboard/db/analytics/migrations/20200101000000_init.up.sql

@@ -51,12 +51,10 @@ CREATE TABLE IF NOT EXISTS actors
     connectable_at DateTime64(9),
     finished_at DateTime64(9),
     destroyed_at DateTime64(9),
-    row_updated_at DateTime64(9),
-
-	INDEX idx_actor_id actor_id TYPE bloom_filter GRANULARITY 1
+    row_updated_at DateTime64(9)
 )
 ENGINE = ReplicatedReplacingMergeTree(row_updated_at)
-PARTITION BY (namespace, env_id, toStartOfHour(created_at))
-ORDER BY (env_id, created_at, actor_id)
+PARTITION BY (namespace, env_id, toStartOfMonth(created_at))
+ORDER BY (namespace, env_id, actor_id, row_updated_at)
 TTL toDate(multiIf(destroyed_at > 0, destroyed_at + toIntervalDay(90), toDateTime64('2099-12-31 23:59:59', 9)))
-SETTINGS index_granularity = 8192, ttl_only_drop_parts = 0;
+SETTINGS index_granularity = 4096, ttl_only_drop_parts = 0;

packages/edge/services/pegboard/src/ops/actor/log/read_with_query.rs

@@ -2,7 +2,6 @@ use chirp_workflow::prelude::*;
 use clickhouse_user_query::{QueryExpr, UserDefinedQueryBuilder};
 
 use crate::schema::ACTOR_LOGS_SCHEMA;
-use crate::types::LogsStreamType;
 
 #[derive(Debug)]
 pub struct Input {
@@ -96,8 +95,6 @@ pub async fn pegboard_actor_log_read_with_query(
 		WHERE
 			namespace = ?
 			AND env_id = ?
-			AND actor_id IN ?
-			AND stream_type IN ?
 			-- Apply timestamp filtering based on query type
 			AND (
 				? -- is_all

shell.nix

@@ -26,6 +26,7 @@ in
 			git-lfs
 			jq
 			openssh  # ssh-keygen
+			go-migrate
 
 			# Compilers
 			clang