Janady13/missionmatch / internal/platform/database/dbgen/mission_tags.sql.go

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: mission_tags.sql 5 6package dbgen 7 8import ( 9 "context" 10 11 "github.com/google/uuid" 12 "github.com/jackc/pgx/v5/pgtype" 13 "github.com/shopspring/decimal" 14) 15 16const listAllOrganizationIDs = `-- name: ListAllOrganizationIDs :many 17SELECT id FROM organizations ORDER BY id 18` 19 20// Every organization id, ordered by id for a byte stable backfill iteration. Read by the BYPASSRLS 21// migrator role in the tag-missions backfill ONLY to enumerate which tenant contexts to run; the tag 22// writes themselves run as the application role inside each org's RunInTenantTx, never the migrator bypass. 23func (q *Queries) ListAllOrganizationIDs(ctx context.Context) ([]uuid.UUID, error) { 24 rows, err := q.db.Query(ctx, listAllOrganizationIDs) 25 if err != nil { 26 return nil, err 27 } 28 defer rows.Close() 29 items := []uuid.UUID{} 30 for rows.Next() { 31 var id uuid.UUID 32 if err := rows.Scan(&id); err != nil { 33 return nil, err 34 } 35 items = append(items, id) 36 } 37 if err := rows.Err(); err != nil { 38 return nil, err 39 } 40 return items, nil 41} 42 43const listAwardsForClassify = `-- name: ListAwardsForClassify :many 44SELECT generated_internal_id AS record_id, description, naics_description, naics_code 45FROM usaspending_awards 46ORDER BY generated_internal_id 47` 48 49type ListAwardsForClassifyRow struct { 50 RecordID string `json:"record_id"` 51 Description string `json:"description"` 52 NaicsDescription string `json:"naics_description"` 53 NaicsCode string `json:"naics_code"` 54} 55 56// Minimal projection of the global usaspending_awards catalog for the missionclass sync pass: the 57// generated_internal_id (the record_id the tag and incumbent role tables key on), plus the description, 58// naics_description, and naics_code the classifier reads. Ordered by generated_internal_id for byte 59// stable iteration. 60func (q *Queries) ListAwardsForClassify(ctx context.Context) ([]ListAwardsForClassifyRow, error) { 61 rows, err := q.db.Query(ctx, listAwardsForClassify) 62 if err != nil { 63 return nil, err 64 } 65 defer rows.Close() 66 items := []ListAwardsForClassifyRow{} 67 for rows.Next() { 68 var i ListAwardsForClassifyRow 69 if err := rows.Scan( 70 &i.RecordID, 71 &i.Description, 72 &i.NaicsDescription, 73 &i.NaicsCode, 74 ); err != nil { 75 return nil, err 76 } 77 items = append(items, i) 78 } 79 if err := rows.Err(); err != nil { 80 return nil, err 81 } 82 return items, nil 83} 84 85const listCandidatesByMission = `-- name: ListCandidatesByMission :many 86SELECT c.id, c.organization_id, c.full_name, c.email, c.headline, c.clearance_level, c.clearance_poly, c.clearance_status, c.clearance_granted_at, c.clearance_expires_at, c.reinvestigation_due_at, c.years_experience, c.location, c.remote, c.relocatable, c.available, c.resume_embedding, c.search_tsv, c.created_at, c.updated_at, c.deleted_at, c.source, c.external_id, c.anonymized_at, c.clearance_provenance, c.clearance_verified_at, c.clearance_compartments, c.source_first_touch, c.source_last_touch, c.source_detail, c.provenance, c.owner_user_id, c.merged_into_id, c.cv_enrolled, c.cv_enrolled_on, c.access_ended_on, c.last_adjudicated_on 87FROM candidates c 88JOIN candidate_mission_tags t ON t.candidate_id = c.id 89WHERE c.deleted_at IS NULL AND t.mission_code = $1 90ORDER BY c.created_at DESC, c.id 91LIMIT $2 92` 93 94type ListCandidatesByMissionParams struct { 95 MissionCode string `json:"mission_code"` 96 RowLimit int32 `json:"row_limit"` 97} 98 99// Tenant candidates tagged with a given mission code, RLS scoped to the caller's org through the join on 100// candidate_mission_tags. id is the trailing unique sort key so created_at ties give a total order and 101// stable LIMIT paging, the AEDT reproducibility mandate. 102func (q *Queries) ListCandidatesByMission(ctx context.Context, arg ListCandidatesByMissionParams) ([]Candidate, error) { 103 rows, err := q.db.Query(ctx, listCandidatesByMission, arg.MissionCode, arg.RowLimit) 104 if err != nil { 105 return nil, err 106 } 107 defer rows.Close() 108 items := []Candidate{} 109 for rows.Next() { 110 var i Candidate 111 if err := rows.Scan( 112 &i.ID, 113 &i.OrganizationID, 114 &i.FullName, 115 &i.Email, 116 &i.Headline, 117 &i.ClearanceLevel, 118 &i.ClearancePoly, 119 &i.ClearanceStatus, 120 &i.ClearanceGrantedAt, 121 &i.ClearanceExpiresAt, 122 &i.ReinvestigationDueAt, 123 &i.YearsExperience, 124 &i.Location, 125 &i.Remote, 126 &i.Relocatable, 127 &i.Available, 128 &i.ResumeEmbedding, 129 &i.SearchTsv, 130 &i.CreatedAt, 131 &i.UpdatedAt, 132 &i.DeletedAt, 133 &i.Source, 134 &i.ExternalID, 135 &i.AnonymizedAt, 136 &i.ClearanceProvenance, 137 &i.ClearanceVerifiedAt, 138 &i.ClearanceCompartments, 139 &i.SourceFirstTouch, 140 &i.SourceLastTouch, 141 &i.SourceDetail, 142 &i.Provenance, 143 &i.OwnerUserID, 144 &i.MergedIntoID, 145 &i.CvEnrolled, 146 &i.CvEnrolledOn, 147 &i.AccessEndedOn, 148 &i.LastAdjudicatedOn, 149 ); err != nil { 150 return nil, err 151 } 152 items = append(items, i) 153 } 154 if err := rows.Err(); err != nil { 155 return nil, err 156 } 157 return items, nil 158} 159 160const listCandidatesForMissionTagging = `-- name: ListCandidatesForMissionTagging :many 161SELECT c.id AS candidate_id, 162 COALESCE(c.headline, '')::text AS headline, 163 COALESCE(string_agg(s.name, ' ' ORDER BY s.name), '')::text AS skill_text 164FROM candidates c 165LEFT JOIN candidate_skills cs ON cs.candidate_id = c.id 166LEFT JOIN skills s ON s.id = cs.skill_id 167WHERE c.deleted_at IS NULL AND c.anonymized_at IS NULL 168GROUP BY c.id, c.headline 169ORDER BY c.id 170` 171 172type ListCandidatesForMissionTaggingRow struct { 173 CandidateID uuid.UUID `json:"candidate_id"` 174 Headline string `json:"headline"` 175 SkillText string `json:"skill_text"` 176} 177 178// Tenant projection the Phase 5a tagging service classifies: each live candidate id, its headline, and the 179// candidate's skill names joined by single spaces into one text blob. RLS scopes the read to the caller's 180// org through the candidates row, and the LEFT JOIN keeps a candidate with no skills (the headline still 181// classifies). headline is coerced to empty text so a NULL never aborts the aggregation. Ordered by id so 182// the pass iterates byte stably and a re run is reproducible, the AEDT mandate. 183func (q *Queries) ListCandidatesForMissionTagging(ctx context.Context) ([]ListCandidatesForMissionTaggingRow, error) { 184 rows, err := q.db.Query(ctx, listCandidatesForMissionTagging) 185 if err != nil { 186 return nil, err 187 } 188 defer rows.Close() 189 items := []ListCandidatesForMissionTaggingRow{} 190 for rows.Next() { 191 var i ListCandidatesForMissionTaggingRow 192 if err := rows.Scan(&i.CandidateID, &i.Headline, &i.SkillText); err != nil { 193 return nil, err 194 } 195 items = append(items, i) 196 } 197 if err := rows.Err(); err != nil { 198 return nil, err 199 } 200 return items, nil 201} 202 203const listIncumbentRolesByRecompete = `-- name: ListIncumbentRolesByRecompete :many 204SELECT a.generated_internal_id AS record_id, 205 a.recipient_name AS recipient_name, 206 a.awarding_agency AS awarding_agency, 207 a.naics_code AS naics_code, 208 a.award_amount AS award_amount, 209 a.pop_end_date AS pop_end_date, 210 r.labor_category AS labor_category, 211 r.role_count AS role_count, 212 r.evidence AS evidence 213FROM award_incumbent_roles r 214JOIN usaspending_awards a ON a.generated_internal_id = r.record_id 215WHERE r.record_table = 'usaspending_awards' 216 AND ($1::date IS NULL OR a.pop_end_date <= $1::date) 217ORDER BY a.pop_end_date ASC NULLS LAST, a.generated_internal_id, r.labor_category 218LIMIT $2::int 219` 220 221type ListIncumbentRolesByRecompeteParams struct { 222 PopEndBefore pgtype.Date `json:"pop_end_before"` 223 RowLimit int32 `json:"row_limit"` 224} 225 226type ListIncumbentRolesByRecompeteRow struct { 227 RecordID string `json:"record_id"` 228 RecipientName string `json:"recipient_name"` 229 AwardingAgency string `json:"awarding_agency"` 230 NaicsCode string `json:"naics_code"` 231 AwardAmount *decimal.Decimal `json:"award_amount"` 232 PopEndDate pgtype.Date `json:"pop_end_date"` 233 LaborCategory string `json:"labor_category"` 234 RoleCount int32 `json:"role_count"` 235 Evidence string `json:"evidence"` 236} 237 238// Incumbent labor mix mined from award text, joined to its parent USASpending award so each role carries 239// the award identity (recipient_name, pop_end_date) and its evidence phrase, the traceability the WS7 240// acceptance criterion requires. The recompete signal is pop_end_date: awards whose period of performance 241// is ending are the recompete relevant ones, so rows are ordered by pop_end_date soonest first, then by 242// the award generated_internal_id and the labor_category as trailing unique tiebreakers for byte stable 243// output, the AEDT reproducibility mandate. Awards with no pop_end_date sort last. Global reference data, 244// app SELECT only. The optional pop_end_before bound (NULL means no bound) lets the caller scope to a 245// recompete window without changing the default which returns the soonest ending awards first. 246func (q *Queries) ListIncumbentRolesByRecompete(ctx context.Context, arg ListIncumbentRolesByRecompeteParams) ([]ListIncumbentRolesByRecompeteRow, error) { 247 rows, err := q.db.Query(ctx, listIncumbentRolesByRecompete, arg.PopEndBefore, arg.RowLimit) 248 if err != nil { 249 return nil, err 250 } 251 defer rows.Close() 252 items := []ListIncumbentRolesByRecompeteRow{} 253 for rows.Next() { 254 var i ListIncumbentRolesByRecompeteRow 255 if err := rows.Scan( 256 &i.RecordID, 257 &i.RecipientName, 258 &i.AwardingAgency, 259 &i.NaicsCode, 260 &i.AwardAmount, 261 &i.PopEndDate, 262 &i.LaborCategory, 263 &i.RoleCount, 264 &i.Evidence, 265 ); err != nil { 266 return nil, err 267 } 268 items = append(items, i) 269 } 270 if err := rows.Err(); err != nil { 271 return nil, err 272 } 273 return items, nil 274} 275 276const listMissionTagsForRecord = `-- name: ListMissionTagsForRecord :many 277SELECT record_table, record_id, mission_code, mechanism, evidence, confidence, classified_at 278FROM federal_mission_tags 279WHERE record_table = $1 AND record_id = $2 280ORDER BY mission_code, record_id 281` 282 283type ListMissionTagsForRecordParams struct { 284 RecordTable string `json:"record_table"` 285 RecordID string `json:"record_id"` 286} 287 288// All mission tags for one global record, ordered by mission code with the record id as a trailing unique 289// tiebreaker so the output is byte stable for fixed inputs, the AEDT reproducibility mandate. 290func (q *Queries) ListMissionTagsForRecord(ctx context.Context, arg ListMissionTagsForRecordParams) ([]FederalMissionTag, error) { 291 rows, err := q.db.Query(ctx, listMissionTagsForRecord, arg.RecordTable, arg.RecordID) 292 if err != nil { 293 return nil, err 294 } 295 defer rows.Close() 296 items := []FederalMissionTag{} 297 for rows.Next() { 298 var i FederalMissionTag 299 if err := rows.Scan( 300 &i.RecordTable, 301 &i.RecordID, 302 &i.MissionCode, 303 &i.Mechanism, 304 &i.Evidence, 305 &i.Confidence, 306 &i.ClassifiedAt, 307 ); err != nil { 308 return nil, err 309 } 310 items = append(items, i) 311 } 312 if err := rows.Err(); err != nil { 313 return nil, err 314 } 315 return items, nil 316} 317 318const listOpportunityRecordsForClassify = `-- name: ListOpportunityRecordsForClassify :many 319SELECT id::text AS record_id, title, psc, naics 320FROM opportunity_records 321ORDER BY id 322` 323 324type ListOpportunityRecordsForClassifyRow struct { 325 RecordID string `json:"record_id"` 326 Title string `json:"title"` 327 Psc string `json:"psc"` 328 Naics string `json:"naics"` 329} 330 331// Minimal projection of the global opportunity_records catalog for the missionclass sync pass: the id 332// carried as text (the record_id federal_mission_tags keys on), plus the title, psc, and naics the 333// deterministic classifier reads. Ordered by id so the pass iterates byte stably and a re run is 334// reproducible, the AEDT mandate. Migrator role reads the global catalog directly. 335func (q *Queries) ListOpportunityRecordsForClassify(ctx context.Context) ([]ListOpportunityRecordsForClassifyRow, error) { 336 rows, err := q.db.Query(ctx, listOpportunityRecordsForClassify) 337 if err != nil { 338 return nil, err 339 } 340 defer rows.Close() 341 items := []ListOpportunityRecordsForClassifyRow{} 342 for rows.Next() { 343 var i ListOpportunityRecordsForClassifyRow 344 if err := rows.Scan( 345 &i.RecordID, 346 &i.Title, 347 &i.Psc, 348 &i.Naics, 349 ); err != nil { 350 return nil, err 351 } 352 items = append(items, i) 353 } 354 if err := rows.Err(); err != nil { 355 return nil, err 356 } 357 return items, nil 358} 359 360const listRequirementsForMissionTagging = `-- name: ListRequirementsForMissionTagging :many 361SELECT r.id AS requirement_id, 362 r.title::text AS title, 363 COALESCE(r.labor_category, '')::text AS labor_category, 364 COALESCE(string_agg(s.name, ' ' ORDER BY s.name), '')::text AS skill_text 365FROM requirements r 366LEFT JOIN required_skills rs ON rs.requirement_id = r.id 367LEFT JOIN skills s ON s.id = rs.skill_id 368WHERE r.deleted_at IS NULL 369GROUP BY r.id, r.title, r.labor_category 370ORDER BY r.id 371` 372 373type ListRequirementsForMissionTaggingRow struct { 374 RequirementID uuid.UUID `json:"requirement_id"` 375 Title string `json:"title"` 376 LaborCategory string `json:"labor_category"` 377 SkillText string `json:"skill_text"` 378} 379 380// Tenant projection the Phase 5a tagging service classifies for requirements: each live requirement id, its 381// title, its labor_category (coerced to empty when NULL), and the required skill names joined by single 382// spaces. RLS scopes the read to the caller's org; the LEFT JOIN keeps a requirement with no required 383// skills (the title and labor category still classify). Ordered by id for byte stable, reproducible 384// iteration, the AEDT mandate. 385func (q *Queries) ListRequirementsForMissionTagging(ctx context.Context) ([]ListRequirementsForMissionTaggingRow, error) { 386 rows, err := q.db.Query(ctx, listRequirementsForMissionTagging) 387 if err != nil { 388 return nil, err 389 } 390 defer rows.Close() 391 items := []ListRequirementsForMissionTaggingRow{} 392 for rows.Next() { 393 var i ListRequirementsForMissionTaggingRow 394 if err := rows.Scan( 395 &i.RequirementID, 396 &i.Title, 397 &i.LaborCategory, 398 &i.SkillText, 399 ); err != nil { 400 return nil, err 401 } 402 items = append(items, i) 403 } 404 if err := rows.Err(); err != nil { 405 return nil, err 406 } 407 return items, nil 408} 409 410const listSamForClassify = `-- name: ListSamForClassify :many 411SELECT notice_id AS record_id, description_url, resource_links 412FROM sam_opportunities 413ORDER BY notice_id 414` 415 416type ListSamForClassifyRow struct { 417 RecordID string `json:"record_id"` 418 DescriptionUrl string `json:"description_url"` 419 ResourceLinks []byte `json:"resource_links"` 420} 421 422// Minimal projection of the cached sam_opportunities catalog for the missionclass sync pass: the 423// notice_id (the record_id award_incumbent_roles keys on for a SAM notice), plus the description_url and 424// the resource_links the attachment fetcher needs to mine the incumbent labor mix. Ordered by notice_id 425// for byte stable iteration. 426func (q *Queries) ListSamForClassify(ctx context.Context) ([]ListSamForClassifyRow, error) { 427 rows, err := q.db.Query(ctx, listSamForClassify) 428 if err != nil { 429 return nil, err 430 } 431 defer rows.Close() 432 items := []ListSamForClassifyRow{} 433 for rows.Next() { 434 var i ListSamForClassifyRow 435 if err := rows.Scan(&i.RecordID, &i.DescriptionUrl, &i.ResourceLinks); err != nil { 436 return nil, err 437 } 438 items = append(items, i) 439 } 440 if err := rows.Err(); err != nil { 441 return nil, err 442 } 443 return items, nil 444} 445 446const missionAliasPairs = `-- name: MissionAliasPairs :many 447SELECT a.alias_text AS phrase, m.code AS code 448FROM skill_aliases a 449JOIN skills s ON s.id = a.skill_id AND s.category = 'mission_area' 450JOIN mission_areas m ON m.spine_term = s.name 451UNION 452SELECT s.name AS phrase, m.code AS code 453FROM skills s 454JOIN mission_areas m ON m.spine_term = s.name 455WHERE s.category = 'mission_area' 456ORDER BY phrase, code 457` 458 459type MissionAliasPairsRow struct { 460 Phrase string `json:"phrase"` 461 Code string `json:"code"` 462} 463 464// (phrase, code) pairs that seed the missionclass AliasIndex from real rows. Two unioned sources: every 465// curated alias whose target skill is a category 'mission_area' skill, and every mission_area skill name 466// itself. The skill name to code link is mission_areas.spine_term = skills.name, because the mission_area 467// skills were promoted from the mission_spine terms the mission_areas rows carry. Ordered by phrase then 468// code for a deterministic build. Global reference data, read by the migrator role. 469func (q *Queries) MissionAliasPairs(ctx context.Context) ([]MissionAliasPairsRow, error) { 470 rows, err := q.db.Query(ctx, missionAliasPairs) 471 if err != nil { 472 return nil, err 473 } 474 defer rows.Close() 475 items := []MissionAliasPairsRow{} 476 for rows.Next() { 477 var i MissionAliasPairsRow 478 if err := rows.Scan(&i.Phrase, &i.Code); err != nil { 479 return nil, err 480 } 481 items = append(items, i) 482 } 483 if err := rows.Err(); err != nil { 484 return nil, err 485 } 486 return items, nil 487} 488 489const upsertAwardIncumbentRole = `-- name: UpsertAwardIncumbentRole :exec 490INSERT INTO award_incumbent_roles (record_table, record_id, labor_category, role_count, evidence) 491VALUES ( 492 $1, 493 $2, 494 $3, 495 $4, 496 $5 497) 498ON CONFLICT (record_table, record_id, labor_category) DO UPDATE SET 499 role_count = EXCLUDED.role_count, 500 evidence = EXCLUDED.evidence, 501 classified_at = now() 502` 503 504type UpsertAwardIncumbentRoleParams struct { 505 RecordTable string `json:"record_table"` 506 RecordID string `json:"record_id"` 507 LaborCategory string `json:"labor_category"` 508 RoleCount int32 `json:"role_count"` 509 Evidence string `json:"evidence"` 510} 511 512// Idempotent write of an incumbent labor mix row mined from award and solicitation text. ON CONFLICT DO 513// UPDATE so a re run refreshes the count and evidence for the same record and labor category. 514func (q *Queries) UpsertAwardIncumbentRole(ctx context.Context, arg UpsertAwardIncumbentRoleParams) error { 515 _, err := q.db.Exec(ctx, upsertAwardIncumbentRole, 516 arg.RecordTable, 517 arg.RecordID, 518 arg.LaborCategory, 519 arg.RoleCount, 520 arg.Evidence, 521 ) 522 return err 523} 524 525const upsertCandidateMissionTag = `-- name: UpsertCandidateMissionTag :exec 526INSERT INTO candidate_mission_tags (organization_id, candidate_id, mission_code, mechanism, evidence) 527VALUES ( 528 $1, 529 $2, 530 $3, 531 $4, 532 $5 533) 534ON CONFLICT (candidate_id, mission_code) DO UPDATE SET 535 mechanism = EXCLUDED.mechanism, 536 evidence = EXCLUDED.evidence 537` 538 539type UpsertCandidateMissionTagParams struct { 540 OrganizationID uuid.UUID `json:"organization_id"` 541 CandidateID uuid.UUID `json:"candidate_id"` 542 MissionCode string `json:"mission_code"` 543 Mechanism string `json:"mechanism"` 544 Evidence string `json:"evidence"` 545} 546 547// Idempotent write of a tenant candidate mission tag. RLS scopes the write to the caller's org and the 548// composite FK guarantees the candidate belongs to that org. ON CONFLICT DO UPDATE keeps the sync pass 549// repeatable, refreshing the mechanism and evidence for an existing candidate and mission code pair. 550func (q *Queries) UpsertCandidateMissionTag(ctx context.Context, arg UpsertCandidateMissionTagParams) error { 551 _, err := q.db.Exec(ctx, upsertCandidateMissionTag, 552 arg.OrganizationID, 553 arg.CandidateID, 554 arg.MissionCode, 555 arg.Mechanism, 556 arg.Evidence, 557 ) 558 return err 559} 560 561const upsertFederalMissionTag = `-- name: UpsertFederalMissionTag :exec 562INSERT INTO federal_mission_tags (record_table, record_id, mission_code, mechanism, evidence, confidence) 563VALUES ( 564 $1, 565 $2, 566 $3, 567 $4, 568 $5, 569 $6 570) 571ON CONFLICT (record_table, record_id, mission_code) DO UPDATE SET 572 mechanism = EXCLUDED.mechanism, 573 evidence = EXCLUDED.evidence, 574 confidence = EXCLUDED.confidence, 575 classified_at = now() 576` 577 578type UpsertFederalMissionTagParams struct { 579 RecordTable string `json:"record_table"` 580 RecordID string `json:"record_id"` 581 MissionCode string `json:"mission_code"` 582 Mechanism string `json:"mechanism"` 583 Evidence string `json:"evidence"` 584 Confidence decimal.Decimal `json:"confidence"` 585} 586 587// Idempotent write of a global mission tag from the classification sync pass. ON CONFLICT DO UPDATE so a 588// re run with the same record and mission code refreshes the mechanism, evidence, and confidence rather 589// than erroring, which keeps the sync pass safely repeatable. Migrator owned, app SELECT only. 590func (q *Queries) UpsertFederalMissionTag(ctx context.Context, arg UpsertFederalMissionTagParams) error { 591 _, err := q.db.Exec(ctx, upsertFederalMissionTag, 592 arg.RecordTable, 593 arg.RecordID, 594 arg.MissionCode, 595 arg.Mechanism, 596 arg.Evidence, 597 arg.Confidence, 598 ) 599 return err 600} 601 602const upsertRequirementMissionTag = `-- name: UpsertRequirementMissionTag :exec 603INSERT INTO requirement_mission_tags (organization_id, requirement_id, mission_code, mechanism, evidence) 604VALUES ( 605 $1, 606 $2, 607 $3, 608 $4, 609 $5 610) 611ON CONFLICT (requirement_id, mission_code) DO UPDATE SET 612 mechanism = EXCLUDED.mechanism, 613 evidence = EXCLUDED.evidence 614` 615 616type UpsertRequirementMissionTagParams struct { 617 OrganizationID uuid.UUID `json:"organization_id"` 618 RequirementID uuid.UUID `json:"requirement_id"` 619 MissionCode string `json:"mission_code"` 620 Mechanism string `json:"mechanism"` 621 Evidence string `json:"evidence"` 622} 623 624// Idempotent write of a tenant requirement mission tag, same isolation guarantees as the candidate path. 625func (q *Queries) UpsertRequirementMissionTag(ctx context.Context, arg UpsertRequirementMissionTagParams) error { 626 _, err := q.db.Exec(ctx, upsertRequirementMissionTag, 627 arg.OrganizationID, 628 arg.RequirementID, 629 arg.MissionCode, 630 arg.Mechanism, 631 arg.Evidence, 632 ) 633 return err 634} 635