Make run_started_at timezone aware

dbt/context/common.py

@@ -1,5 +1,6 @@
 import json
 import os
+import pytz
 import voluptuous
 
 from dbt.adapters.factory import get_adapter
@@ -277,6 +278,9 @@ def generate(model, project, flat_graph, provider=None):
         "graph": flat_graph,
         "log": log,
         "model": model,
+        "modules": {
+            "pytz": pytz,
+        },
         "post_hooks": post_hooks,
         "pre_hooks": pre_hooks,
         "ref": provider.ref(model, project, profile, flat_graph),

dbt/tracking.py

@@ -4,6 +4,7 @@
 from snowplow_tracker import SelfDescribingJson, disable_contracts
 from datetime import datetime
 
+import pytz
 import platform
 import uuid
 import yaml
@@ -44,7 +45,7 @@ def __init__(self):
 
         self.id = None
         self.invocation_id = str(uuid.uuid4())
-        self.run_started_at = datetime.now()
+        self.run_started_at = datetime.now(tz=pytz.utc)
 
     def state(self):
         return "do not track" if self.do_not_track else "tracking"

dev_requirements.txt

@@ -1,6 +1,8 @@
+freezegun==0.3.9
 nose>=1.3.7
 mock>=1.3.0
 pep8>=1.6.2
+pytz==2017.2
 bumpversion==0.5.3
 coverage==4.2
 tox==2.5.0

requirements.txt

@@ -1,5 +1,7 @@
 argparse>=1.2.1
+freezegun==0.3.9
 Jinja2>=2.8
+pytz==2017.2
 PyYAML>=3.11
 psycopg2==2.7.1
 sqlparse==0.2.3

setup.py

@@ -31,7 +31,9 @@
         'scripts/dbt',
     ],
     install_requires=[
+        'freezegun==0.3.9',
         'Jinja2>=2.8',
+        'pytz==2017.2',
         'PyYAML>=3.11',
         'psycopg2==2.7.1',
         'sqlparse==0.2.3',

test/integration/025_timezones_test/models/timezones.sql

@@ -0,0 +1,10 @@
+
+{{
+    config(
+        materialized='table'
+    )
+}}
+
+select
+    '{{ run_started_at.astimezone(modules.pytz.timezone("America/New_York")) }}' as run_started_at_est,
+    '{{ run_started_at }}' as run_started_at_utc

test/integration/025_timezones_test/test_timezones.py

@@ -0,0 +1,55 @@
+from freezegun import freeze_time
+from nose.plugins.attrib import attr
+from test.integration.base import DBTIntegrationTest
+
+
+class TestTimezones(DBTIntegrationTest):
+
+    def setUp(self):
+        DBTIntegrationTest.setUp(self)
+
+    @property
+    def schema(self):
+        return "timezones_025"
+
+    @property
+    def models(self):
+        return "test/integration/025_timezones_test/models"
+
+    @property
+    def profile_config(self):
+        return {
+            'test': {
+                'outputs': {
+                    'dev': {
+                        'type': 'postgres',
+                        'threads': 1,
+                        'host': 'database',
+                        'port': 5432,
+                        'user': "root",
+                        'pass': "password",
+                        'dbname': 'dbt',
+                        'schema': self.unique_schema()
+                    },
+                },
+                'target': 'dev'
+            }
+        }
+
+    @property
+    def query(self):
+        return """
+            select
+              run_started_at_est,
+              run_started_at_utc
+            from {schema}.timezones
+        """.format(schema=self.unique_schema())
+
+    @freeze_time("2017-01-01 03:00:00", tz_offset=0)
+    @attr(type='postgres')
+    def test_run_started_at(self):
+        self.run_dbt(['run'])
+        result = self.run_sql(self.query, fetch='all')[0]
+        est, utc = result
+        self.assertEqual(utc, '2017-01-01 03:00:00+00:00')
+        self.assertEqual(est, '2016-12-31 22:00:00-05:00')