ian-whitestone

with sample_data as (
    select *
    from snowflake_sample_data.tpch_sf1.customer
),

nation_14_customers as (
    select *
    from sample_data
    where c_nationkey = 14
),

ian-whitestone

{% macro set_query_tag() -%}
    {# Start with any model-configured dict #}
    {% set tag_dict = config.get('query_tag', default={}) %}

    {# Regardless of resource type, we can always access the config via the 'model' variable #}
    {%- do tag_dict.update(
        dbt_snowflake_query_tags_version='1.1.3',
        app='dbt',
        dbt_version=dbt_version,
        project_name=project_name,

ian-whitestone

<script src="https://cdn.jsdelivr.net/npm/canvas-confetti@1.4.0/dist/confetti.browser.min.js"></script>
 <script src="https://ajax.googleapis.com/ajax/libs/jquery/3.6.0/jquery.min.js"></script>
 
 
 <div id="bottom_of_page">Thanks for scrolling to the bottom 🙌</div>
 
 <div>Enjoy some confetti 🎉</div>
 
 <script>
 

ian-whitestone

import os

from jinja2 import Environment, meta, Template
import pandas as pd
from pandas.testing import assert_frame_equal
import pandas.io.sql as psql
import psycopg2

# All these constants would likely live in separate files
CONNECTION = psycopg2.connect(

ian-whitestone

ian-whitestone

import numpy as np

def bayesian_rate_comparison(
    control_successes, 
    control_samples, 
    test_successes, 
    test_samples,
    prior_a=0,
    prior_b=0
):

ian-whitestone

ian-whitestone

import logging
import time
from dataclasses import dataclass
from typing import Any, Optional, Tuple

import requests
import yaml
from distributed import Client
from distributed.security import Security
from googleapiclient import discovery

ian-whitestone

FROM python:3.7.6-buster

# Set the working directory
RUN mkdir /opt/app
WORKDIR /opt/app

# Copy poetry files into docker image
COPY pyproject.toml .
COPY poetry.lock .

ian-whitestone

from __future__ import unicode_literals

import pytest

from starscream.pipeline.stage import TransformStage

from pyspark.sql import functions as F, types as T

from starscream.contract import Contract
from starscream.utils.dataframe import as_dicts, from_dicts