Error while referring mongodb native query in another question

Hi Team,

I have created a new native query in mongodb which runs fine when executed from the query editor, however when I save the question and refer it in another question I get the following error. Please help me understand what's wrong in the query

Diagnostic info:

{
"browser-info": {
"language": "en-IN",
"platform": "MacIntel",
"userAgent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/112.0.0.0 Safari/537.36 Edg/112.0.1722.64",
"vendor": "Google Inc."
},
"system-info": {
"file.encoding": "UTF-8",
"java.runtime.name": "OpenJDK Runtime Environment",
"java.runtime.version": "17.0.7+7",
"java.vendor": "Eclipse Adoptium",
"java.vendor.url": "https://adoptium.net/",
"java.version": "17.0.7",
"java.vm.name": "OpenJDK 64-Bit Server VM",
"java.vm.version": "17.0.7+7",
"os.name": "Mac OS X",
"os.version": "13.3.1",
"user.language": "en",
"user.timezone": "Asia/Kolkata"
},
"metabase-info": {
"databases": [
"mongo"
],
"hosting-env": "unknown",
"application-database": "h2",
"application-database-details": {
"database": {
"name": "H2",
"version": "2.1.212 (2022-04-09)"
},
"jdbc-driver": {
"name": "H2 JDBC Driver",
"version": "2.1.212 (2022-04-09)"
}
},
"run-mode": "prod",
"version": {
"date": "2023-04-28",
"tag": "v0.46.2",
"branch": "release-x.46.x",
"hash": "8967c94"
},
"settings": {
"report-timezone": null
}
}
}

Stacktrace:

[20130669-e82f-4196-904a-56140c851498] 2023-05-01T21:35:00+05:30 INFO metabase.api.dataset Source query for this query is Card 108
[20130669-e82f-4196-904a-56140c851498] 2023-05-01T21:35:00+05:30 ERROR metabase.query-processor.middleware.catch-exceptions Error processing query: Input to trim-sql-query does not match schema:

   [nil (named (not (instance? java.lang.String a-clojure.lang.PersistentArrayMap)) query-str)]  

{:database_id 3,
:started_at #t "2023-05-01T21:35:00.392370+05:30[Asia/Kolkata]",
:error_type :invalid-query,
:json_query
{:database 3,
:query {:source-table "card__108"},
:type "query",
:parameters [],
:middleware {:js-int-to-string? true, :add-default-userland-constraints? true}},
:native nil,
:status :failed,
:class clojure.lang.ExceptionInfo,
:stacktrace
["--> query_processor.middleware.fetch_source_query$fn__64705$trim_sql_query__64710.invoke(fetch_source_query.clj:94)"
"query_processor.middleware.fetch_source_query$source_query.invokeStatic(fetch_source_query.clj:121)"
"query_processor.middleware.fetch_source_query$source_query.invoke(fetch_source_query.clj:106)"
"query_processor.middleware.fetch_source_query$fn__64747$card_id__GT_source_query_and_metadata__64756$fn__64759.invoke(fetch_source_query.clj:142)"
"query_processor.middleware.fetch_source_query$fn__64747$card_id__GT_source_query_and_metadata__64756.invoke(fetch_source_query.clj:126)"
"query_processor.middleware.fetch_source_query$fn__64747$card_id__GT_source_query_and_metadata__64756$fn__64757.invoke(fetch_source_query.clj:130)"
"query_processor.middleware.fetch_source_query$fn__64747$card_id__GT_source_query_and_metadata__64756.invoke(fetch_source_query.clj:126)"
"query_processor.middleware.fetch_source_query$check_for_circular_references.invokeStatic(fetch_source_query.clj:217)"
"query_processor.middleware.fetch_source_query$check_for_circular_references.invoke(fetch_source_query.clj:209)"
"query_processor.middleware.fetch_source_query$check_for_circular_references.invokeStatic(fetch_source_query.clj:214)"
"query_processor.middleware.fetch_source_query$check_for_circular_references.invoke(fetch_source_query.clj:209)"
"query_processor.middleware.fetch_source_query$fn__64907$resolve_all__64912$fn__64913.invoke(fetch_source_query.clj:279)"
"query_processor.middleware.fetch_source_query$fn__64907$resolve_all__64912.invoke(fetch_source_query.clj:272)"
"query_processor.middleware.fetch_source_query$fn__64931$resolve_card_id_source_tables_STAR___64936$fn__64940.invoke(fetch_source_query.clj:295)"
"query_processor.middleware.fetch_source_query$fn__64931$resolve_card_id_source_tables_STAR___64936.invoke(fetch_source_query.clj:286)"
"query_processor.middleware.fetch_source_query$resolve_card_id_source_tables$fn__64953.invoke(fetch_source_query.clj:302)"
"query_processor.middleware.store$initialize_store$fn__65131$fn__65132.invoke(store.clj:12)"
"query_processor.store$do_with_store.invokeStatic(store.clj:47)"
"query_processor.store$do_with_store.invoke(store.clj:41)"
"query_processor.middleware.store$initialize_store$fn__65131.invoke(store.clj:11)"
"query_processor.middleware.normalize_query$normalize$fn__69372.invoke(normalize_query.clj:25)"
"query_processor.middleware.constraints$add_default_userland_constraints$fn__66309.invoke(constraints.clj:54)"
"query_processor.middleware.process_userland_query$process_userland_query$fn__69308.invoke(process_userland_query.clj:150)"
"query_processor.middleware.catch_exceptions$catch_exceptions$fn__69685.invoke(catch_exceptions.clj:171)"
"query_processor.reducible$async_qp$qp_STAR___59455$thunk__59457.invoke(reducible.clj:103)"
"query_processor.reducible$async_qp$qp_STAR___59455.invoke(reducible.clj:109)"
"query_processor.reducible$async_qp$qp_STAR___59455.invoke(reducible.clj:94)"
"query_processor.reducible$sync_qp$qp_STAR___59467.doInvoke(reducible.clj:129)"
"query_processor$process_userland_query.invokeStatic(query_processor.clj:362)"
"query_processor$process_userland_query.doInvoke(query_processor.clj:358)"
"query_processor$fn__70739$process_query_and_save_execution_BANG___70748$fn__70751.invoke(query_processor.clj:373)"
"query_processor$fn__70739$process_query_and_save_execution_BANG___70748.invoke(query_processor.clj:366)"
"query_processor$fn__70784$process_query_and_save_with_max_results_constraints_BANG___70793$fn__70796.invoke(query_processor.clj:385)"
"query_processor$fn__70784$process_query_and_save_with_max_results_constraints_BANG___70793.invoke(query_processor.clj:378)"
"api.dataset$run_query_async$fn__86545.invoke(dataset.clj:73)"
"query_processor.streaming$streaming_response_STAR_$fn__54305$fn__54306.invoke(streaming.clj:166)"
"query_processor.streaming$streaming_response_STAR_$fn__54305.invoke(streaming.clj:165)"
"async.streaming_response$do_f_STAR_.invokeStatic(streaming_response.clj:69)"
"async.streaming_response$do_f_STAR_.invoke(streaming_response.clj:67)"
"async.streaming_response$do_f_async$task__36922.invoke(streaming_response.clj:88)"],
:card_id 108,
:context :ad-hoc,
:error
"Input to trim-sql-query does not match schema: \n\n\t [nil (named (not (instance? java.lang.String a-clojure.lang.PersistentArrayMap)) query-str)] \n\n",
:row_count 0,
:running_time 0,
:preprocessed nil,
:ex-data
{:type :schema.core/error,
:value
[108
{:collection "user",
:query
"[{"$project":{"_id":"$_id","updateDateTime":"$updateDateTime","createDateTime":"$createDateTime","givenName":"$givenName","familyName":"$familyName","gender":"$gender","email":"$email","roles":"$roles","timezone":"$timezone","lastLoginDateTime":{"$dateFromString":{"dateString":"$lastLoginDateTime","onError":"$lastLoginDateTime"}},"dateOfBirth":"$dateOfBirth","stats":"$stats","lastSubmitDateTime":"$lastSubmitDateTime","boardingStatus":"$boardingStatus","finishedOnboarding":"$finishedOnboarding","biologicalSex":"$biologicalSex","TaskCompliance":{"$cond":[{"$eq":["$stats.taskCompliance.total",0]},null,{"$divide":["$stats.taskCompliance.current","$stats.taskCompliance.total"]}]},"FullName":{"$concat":["$givenName"," ","$familyName"]},"Status":{"$cond":[{"$ne":["$boardingStatus.status",0]},"Offboarded","Active"]}}},{"$unwind":"$roles"},{"$match":{"$or":[{"roles.roleId":"User"},{"roles.roleId":"Proxy"}]}},{"$addFields":{"deploymentId":{"$cond":[{"$eq":[{"$first":{"$split":["$roles.resource","/"]}},"deployment"]},{"$last":{"$split":["$roles.resource","/"]}},null]}}},{"$match":{"deploymentId":{"$exists":true}}},{"$limit":1048575}]"}],
:error [nil (named (not (instance? java.lang.String a-clojure.lang.PersistentArrayMap)) query-str)]},
:data {:rows [], :cols []}}

[20130669-e82f-4196-904a-56140c851498] 2023-05-01T21:35:00+05:30 DEBUG metabase.server.middleware.log POST /api/dataset 202 [ASYNC: completed] 72.3 ms (11 DB calls) App DB connections: 0/10 Jetty threads: 4/50 (8 idle, 0 queued) (66 total active threads) Queries in flight: 0 (0 queued)
[20130669-e82f-4196-904a-56140c851498] 2023-05-01T21:35:36+05:30 DEBUG metabase.server.middleware.log GET /api/util/bug_report_details 200 11.2 ms (1 DB calls) App DB connections: 0/10 Jetty threads: 5/50 (11 idle, 0 queued) (62 total active threads) Queries in flight: 0 (0 queued)

Team, Can someone help me on this issue?

FYI, removing null from native query seems to resolve above error but I run into another error:

StackTrace:

[aa40306e-6794-4294-8780-5b564aa824ac] 2023-05-02T11:41:12+05:30 ERROR metabase.query-processor.middleware.catch-exceptions Error processing query: Closed
{:database_id 3,
:started_at #t "2023-05-02T11:41:09.767317+05:30[Asia/Kolkata]",
:json_query
{:constraints {:max-results 10000, :max-results-bare-rows 2000},
:type :native,
:middleware {:js-int-to-string? true, :ignore-cached-results? false, :process-viz-settings? false},
:native
{:template-tags {},
:query
"[{"$project":{"_id":"$id","updateDateTime":"$updateDateTime","createDateTime":"$createDateTime","givenName":"$givenName","familyName":"$familyName","gender":"$gender","email":"$email","roles":"$roles","timezone":"$timezone","lastLoginDateTime":{"$dateFromString":{"dateString":"$lastLoginDateTime","onError":"$lastLoginDateTime"}},"dateOfBirth":"$dateOfBirth","stats":"$stats","lastSubmitDateTime":"$lastSubmitDateTime","boardingStatus":"$boardingStatus","finishedOnboarding":"$finishedOnboarding","biologicalSex":"$biologicalSex","TaskCompliance":{"$cond":[{"$eq":["$stats.taskCompliance.total",0]},-1,{"$divide":["$stats.taskCompliance.current","$stats.taskCompliance.total"]}]},"FullName":{"$concat":["$givenName"," ","$familyName"]},"Status":{"$cond":[{"$ne":["$boardingStatus.status",0]},"Offboarded","Active"]}}},{"$unwind":"$roles"},{"$match":{"$or":[{"roles.roleId":"User"},{"roles.roleId":"Proxy"}]}},{"$addFields":{"deploymentId":{"$cond":[{"$eq":[{"$first":{"$split":["$roles.resource","/"]}},"deployment"]},{"$last":{"$split":["$roles.resource","/"]}},"empty"]}}},{"$limit":1048575}]",
:collection "user"},
:database 3,
:parameters [],
:async? true,
:cache-ttl nil},
:status :failed,
:class org.eclipse.jetty.io.EofException,
:stacktrace
["org.eclipse.jetty.server.HttpOutput.checkWritable(HttpOutput.java:750)"
"org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:780)"
"java.base/java.io.OutputStream.write(OutputStream.java:127)"
"java.base/java.util.zip.GZIPOutputStream.writeHeader(GZIPOutputStream.java:191)"
"java.base/java.util.zip.GZIPOutputStream.(GZIPOutputStream.java:97)"
"java.base/java.util.zip.GZIPOutputStream.(GZIPOutputStream.java:134)"
"--> async.streaming_response$output_stream_delay$fn__36932.invoke(streaming_response.clj:111)"
"async.streaming_response$delay_output_stream$fn__36941.invoke(streaming_response.clj:128)"
"async.streaming_response.proxy$java.io.OutputStream$ff19274a.write(Unknown Source)"
"query_processor.streaming.json$fn$reify__53430.finish_BANG
(json.clj:95)"
"query_processor.streaming$streaming_reducedf$fn__54255.invoke(streaming.clj:132)"
"query_processor.context$reducedf.invokeStatic(context.clj:78)"
"query_processor.context$reducedf.invoke(context.clj:73)"
"query_processor.context.default$default_reducef.invokeStatic(default.clj:64)"
"query_processor.context.default$default_reducef.invoke(default.clj:49)"
"query_processor.context$reducef.invokeStatic(context.clj:70)"
"query_processor.context$reducef.invoke(context.clj:63)"
"query_processor.context.default$default_runf$respond_STAR___53333.invoke(default.clj:69)"
"driver.mongo.execute$reduce_results.invokeStatic(execute.clj:166)"
"driver.mongo.execute$reduce_results.invoke(execute.clj:159)"
"driver.mongo.execute$execute_reducible_query.invokeStatic(execute.clj:185)"
"driver.mongo.execute$execute_reducible_query.invoke(execute.clj:173)"
"driver.mongo$fn__120607$f__119429__auto____120608.invoke(mongo.clj:308)"
"driver.mongo.util$do_with_mongo_connection$fn__119417.invoke(util.clj:230)"
"util.ssh$do_with_ssh_tunnel.invokeStatic(ssh.clj:141)"
"util.ssh$do_with_ssh_tunnel.invoke(ssh.clj:130)"
"driver.mongo.util$do_with_mongo_connection.invokeStatic(util.clj:224)"
"driver.mongo.util$do_with_mongo_connection.invoke(util.clj:219)"
"driver.mongo$fn__120607.invokeStatic(mongo.clj:307)"
"driver.mongo$fn__120607.invoke(mongo.clj:305)"
"query_processor.context$executef.invokeStatic(context.clj:60)"
"query_processor.context$executef.invoke(context.clj:49)"
"query_processor.context.default$default_runf.invokeStatic(default.clj:68)"
"query_processor.context.default$default_runf.invoke(default.clj:66)"
"query_processor.context$runf.invokeStatic(context.clj:46)"
"query_processor.context$runf.invoke(context.clj:40)"
"query_processor.reducible$identity_qp.invokeStatic(reducible.clj:15)"
"query_processor.reducible$identity_qp.invoke(reducible.clj:12)"
"query_processor.middleware.cache$maybe_return_cached_results$maybe_return_cached_results_STAR___69172.invoke(cache.clj:224)"
"query_processor.middleware.permissions$check_query_permissions$fn__64644.invoke(permissions.clj:126)"
"query_processor.middleware.mbql_to_native$mbql__GT_native$fn__68063.invoke(mbql_to_native.clj:24)"
"query_processor$fn__70691$combined_post_process__70696$combined_post_process_STAR___70697.invoke(query_processor.clj:243)"
"query_processor$fn__70691$combined_pre_process__70692$combined_pre_process_STAR___70693.invoke(query_processor.clj:240)"
"query_processor.middleware.resolve_database_and_driver$resolve_database_and_driver$fn__69083$fn__69088.invoke(resolve_database_and_driver.clj:36)"
"driver$do_with_driver.invokeStatic(driver.clj:90)"
"driver$do_with_driver.invoke(driver.clj:86)"
"query_processor.middleware.resolve_database_and_driver$resolve_database_and_driver$fn__69083.invoke(resolve_database_and_driver.clj:35)"
"query_processor.middleware.fetch_source_query$resolve_card_id_source_tables$fn__64953.invoke(fetch_source_query.clj:310)"
"query_processor.middleware.store$initialize_store$fn__65131$fn__65132.invoke(store.clj:12)"
"query_processor.store$do_with_store.invokeStatic(store.clj:47)"
"query_processor.store$do_with_store.invoke(store.clj:41)"
"query_processor.middleware.store$initialize_store$fn__65131.invoke(store.clj:11)"
"query_processor.middleware.normalize_query$normalize$fn__69372.invoke(normalize_query.clj:25)"
"query_processor.middleware.constraints$add_default_userland_constraints$fn__66309.invoke(constraints.clj:54)"
"query_processor.middleware.process_userland_query$process_userland_query$fn__69308.invoke(process_userland_query.clj:150)"
"query_processor.middleware.catch_exceptions$catch_exceptions$fn__69685.invoke(catch_exceptions.clj:171)"
"query_processor.reducible$async_qp$qp_STAR___59455$thunk__59457.invoke(reducible.clj:103)"
"query_processor.reducible$async_qp$qp_STAR___59455$fn__59459.invoke(reducible.clj:108)"],
:card_id 108,
:context :question,
:error "Closed",
:row_count 0,
:running_time 0,
:data {:rows [], :cols []}}