We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8d72af7 commit 0193aadCopy full SHA for 0193aad
src/infra/src/scheduler/mysql.rs
@@ -480,10 +480,9 @@ SELECT CAST(COUNT(*) AS SIGNED) AS num FROM scheduled_jobs;"#,
480
async fn add_data_column() -> Result<()> {
481
log::info!("[MYSQL] Adding data column to scheduled_jobs table");
482
let pool = CLIENT.clone();
483
- if let Err(e) =
484
- sqlx::query(r#"ALTER TABLE scheduled_jobs ADD COLUMN data TEXT NOT NULL DEFAULT ('');"#)
485
- .execute(&pool)
486
- .await
+ if let Err(e) = sqlx::query(r#"ALTER TABLE scheduled_jobs ADD COLUMN data LONGTEXT NOT NULL;"#)
+ .execute(&pool)
+ .await
487
{
488
if !e.to_string().contains("Duplicate column name") {
489
// Check for the specific MySQL error code for duplicate column
0 commit comments