From f6364844f487a41f1fef242488d56949161e4727 Mon Sep 17 00:00:00 2001 From: Eduardo de la Arada Date: Sun, 1 Dec 2024 14:09:17 +0100 Subject: [PATCH] Use DefaultDataset in Job --- server/handler.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/server/handler.go b/server/handler.go index 7492beb3c..a6cd01a8c 100644 --- a/server/handler.go +++ b/server/handler.go @@ -1400,13 +1400,17 @@ func (h *jobsInsertHandler) Handle(ctx context.Context, r *jobsInsertRequest) (* return nil, fmt.Errorf("failed to start transaction: %w", err) } defer tx.RollbackIfNotCommitted() + datasetId := "" + if job.Configuration.Query.DefaultDataset != nil { + datasetId = job.Configuration.Query.DefaultDataset.DatasetId + } hasDestinationTable := job.Configuration.Query.DestinationTable != nil startTime := time.Now() response, jobErr := r.server.contentRepo.Query( ctx, tx, r.project.ID, - "", + datasetId, job.Configuration.Query.Query, job.Configuration.Query.QueryParameters, )