Fix thread values

dbt/project.py

@@ -145,6 +145,9 @@ def compile_target(self, target_cfg):
 
             compiled[key] = compiled_val
 
+        if self.args and hasattr(self.args, 'threads') and self.args.threads:
+            compiled['threads'] = self.args.threads
+
         return compiled
 
     def compile_and_update_target(self):

test/integration/031_thread_count_test/models/do_nothing_1.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_10.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_11.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_12.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_13.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_14.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_15.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_16.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_17.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_18.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_19.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_2.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_20.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_3.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_4.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_5.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_6.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_7.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_8.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/models/do_nothing_9.sql

@@ -0,0 +1 @@
+with x as (select pg_sleep(1)) select 1

test/integration/031_thread_count_test/test_thread_count.py

@@ -0,0 +1,33 @@
+from nose.plugins.attrib import attr
+from test.integration.base import DBTIntegrationTest, FakeArgs
+
+from dbt.task.test import TestTask
+from dbt.project import read_project
+import os
+
+
+class TestDataTests(DBTIntegrationTest):
+
+    @property
+    def project_config(self):
+        return {}
+
+    @property
+    def profile_config(self):
+        return {
+            'threads': 2,
+        }
+
+    @property
+    def schema(self):
+        return "thread_tests_031"
+
+    @property
+    def models(self):
+        return "test/integration/031_thread_count_test/models"
+
+    @attr(type='postgres')
+    def test_postgres_threading_8x(self):
+        self.use_profile('postgres')
+
+        self.run_dbt(args=['run', '--threads', '16'])