app/storage/clickhouse/client.go

@@ -71,5 +71,23 @@ func Migrate() error {
 		log.Fatal(err)
 		return err
 	}
+
+	err = Connection.Exec(
+		context.TODO(),
+		`CREATE TABLE IF NOT EXISTS tasks (
+			timestamp         DateTime,
+			service_name      LowCardinality(String),
+			queue_name        LowCardinality(String),
+			success           Bool,
+			execution_time_ms UInt32
+		)
+		ENGINE = MergeTree
+		PARTITION BY toYYYYMM(timestamp)
+		ORDER BY (service_name, queue_name, timestamp);`,
+	)
+	if err != nil {
+		log.Fatal(err)
+		return err
+	}
 	return nil
 }