feat: add action to check bucket name

.github/workflows/check-bucket-name.yml

@@ -0,0 +1,39 @@
+name: Check bucket name
+on:
+  workflow_dispatch:
+  pull_request:
+    paths:
+      - '**/*.sql'
+
+jobs:
+  check_bucket_name:
+    runs-on: ubuntu-latest
+
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v2
+
+    - name: Get changed files
+      id: get_files
+      uses: dorny/paths-filter@v2
+      with:
+        list-files: shell
+        filters: |
+          pr:
+            - added|deleted|modified: '**'
+
+    - name: Install Python
+      uses: actions/setup-python@v2
+      with:
+        python-version: '3.x'
+
+    - name: Run Python script
+      run: |
+        for file in ${{ steps.get_files.outputs.pr_files }}; do
+          if [[ $file == *.sql ]]; then
+            echo "SQL file detected: $file"
+            python .github/workflows/scripts/check_sql_files.py $file
+          else
+            echo "Não é um arquivo SQL: $file"
+          fi
+        done

.github/workflows/scripts/check_sql_files.py

@@ -0,0 +1,23 @@
+import argparse
+
+def check_sql_files(file):
+    found_staging = False
+    if file.endswith(".sql"):
+        with open(file, "r") as f:
+            lines = f.readlines()
+            for line in lines:
+                if "basedosdados-staging" in line:
+                    found_staging = True
+                    print(f"Found 'basedosdados-staging' in {file}")
+                    break
+    return found_staging
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser(description="Check for 'basedosdados-staging' occurrences in SQL files.")
+    parser.add_argument("file", help="Path to the SQL file to check")
+    args = parser.parse_args()
+
+    if check_sql_files(args.file):
+        exit(1)
+    else:
+        print("No occurrences of 'basedosdados-staging' found in SQL files.")

models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bpc.sql

@@ -32,7 +32,7 @@ select
     safe_cast(numero as string) numero_beneficio,
     safe_cast(concedido_judicialmente as string) concedido_judicialmente,
     safe_cast(valor as float64) valor_parcela,
-from `basedosdados-dev.br_cgu_beneficios_cidadao_staging.bpc` t1
+from `basedosdados-staging.br_cgu_beneficios_cidadao_staging.bpc` t1
 left join
     `basedosdados.br_bd_diretorios_brasil.municipio` t2
     on safe_cast(t1.id_municipio_siafi as int64)