diff --git a/backend/sqlx-data.json b/backend/sqlx-data.json index 8bbb702e08..2b8a75b2b9 100644 --- a/backend/sqlx-data.json +++ b/backend/sqlx-data.json @@ -575,6 +575,37 @@ "nullable": [] } }, + "2e11e3ef361c41e6e055dd4805cb9d5e45eaa486e35fc5f01dae311189d6800f": { + "query": "SELECT language as \"language: ScriptLang\" FROM script WHERE hash = $1 AND (workspace_id = $2 OR workspace_id = 'starter')", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "language: ScriptLang", + "type_info": { + "Custom": { + "name": "script_lang", + "kind": { + "Enum": [ + "python3", + "deno" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Int8", + "Text" + ] + }, + "nullable": [ + false + ] + } + }, "37d3ee8009055e869941e548a6d5a352053a5d7782f662c34b94706488abccb6": { "query": "UPDATE queue SET running = false WHERE last_ping < $1 RETURNING id", "describe": { diff --git a/backend/src/jobs.rs b/backend/src/jobs.rs index 524ca2274c..79230cc8aa 100644 --- a/backend/src/jobs.rs +++ b/backend/src/jobs.rs @@ -1018,7 +1018,17 @@ pub async fn push<'c>( let (script_hash, script_path, raw_code, job_kind, raw_flow, language) = match job_payload { JobPayload::ScriptHash { hash, path } => { - (Some(hash.0), Some(path), None, JobKind::Script, None, None) + let language = sqlx::query_scalar!("SELECT language as \"language: ScriptLang\" FROM script WHERE hash = $1 AND (workspace_id = $2 OR workspace_id = 'starter')", hash.0, workspace_id) + .fetch_one(&mut tx) + .await?; + ( + Some(hash.0), + Some(path), + None, + JobKind::Script, + None, + Some(language), + ) } JobPayload::Code(RawCode { content,