fix benchmarks

backend/windmill-common/src/worker.rs

@@ -146,13 +146,13 @@ fn format_pull_query(peek: String) -> String {
             WHERE id = (SELECT id FROM peek)
         ) SELECT j.id, j.workspace_id, j.parent_job, j.created_by, started_at, scheduled_for,
             j.runnable_id, j.runnable_path, j.args, canceled_by,
-            canceled_reason, j.kind, j.trigger, j.trigger_kind, j.permissioned_as, j.permissioned_as_email,
+            canceled_reason, j.kind, j.trigger, j.trigger_kind, j.permissioned_as, 
             flow_status, j.script_lang,
             j.same_worker, j.pre_run_error, j.visible_to_owner, 
             j.tag, j.concurrent_limit, j.concurrency_time_window_s, j.flow_innermost_root_job,
             j.timeout, j.flow_step_id, j.cache_ttl, j.priority, j.raw_code, j.raw_lock, j.raw_flow,
             j.script_entrypoint_override, j.preprocessed, pj.runnable_path as parent_runnable_path,
-            p.email as permissioned_as_email, p.username as permissioned_as_username, p.is_admin as permissioned_as_is_admin, 
+            COALESCE(p.email, j.permissioned_as_email) as permissioned_as_email, p.username as permissioned_as_username, p.is_admin as permissioned_as_is_admin, 
             p.is_operator as permissioned_as_is_operator, p.groups as permissioned_as_groups, p.folders as permissioned_as_folders
         FROM q, j
             LEFT JOIN v2_job_status f USING (id)

backend/windmill-queue/src/jobs.rs

@@ -4029,7 +4029,7 @@ pub async fn push<'c, 'd>(
             }
             _ => {
                 if authed.is_some() {
-                    tracing::warn!("Authed passed to push is not the same as permissioned_as, refetching direclty permissions for job {job_id}...")
+                    tracing::warn!("Authed passed to push is not the same as permissioned_as, refetching directly permissions for job {job_id}...")
                 }
                 fetch_authed_from_permissioned_as(
                     permissioned_as.clone(),