wassname/catalyst
1
0
Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-07-03 00:50:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

STY: Moving args to new line

Browse Source
This commit is contained in:
Richard Frank
2015-10-10 00:07:05 -04:00
parent ee26a21855
commit 7a638e4580
1 changed files with 23 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/pipeline/test_engine.py
+23 -16
View File
@@ -162,8 +162,9 @@ class ConstantInputTestCase(TestCase):
def test_bad_dates(self):
loader = self.loader
engine = SimplePipelineEngine(lambda column: loader,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column: loader, self.dates, self.asset_finder,
)
p = Pipeline()
@@ -177,8 +178,9 @@ class ConstantInputTestCase(TestCase):
loader = self.loader
finder = self.asset_finder
assets = array(self.assets)
engine = SimplePipelineEngine(lambda column: loader,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column: loader, self.dates, self.asset_finder,
)
num_dates = 5
dates = self.dates[10:10 + num_dates]
@@ -201,8 +203,9 @@ class ConstantInputTestCase(TestCase):
loader = self.loader
finder = self.asset_finder
assets = self.assets
engine = SimplePipelineEngine(lambda column: loader,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column: loader, self.dates, self.asset_finder,
)
result_shape = (num_dates, num_assets) = (5, len(assets))
dates = self.dates[10:10 + num_dates]
@@ -235,8 +238,9 @@ class ConstantInputTestCase(TestCase):
loader = self.loader
finder = self.asset_finder
assets = self.assets
engine = SimplePipelineEngine(lambda column: loader,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column: loader, self.dates, self.asset_finder,
)
shape = num_dates, num_assets = (5, len(assets))
dates = self.dates[10:10 + num_dates]
@@ -279,8 +283,9 @@ class ConstantInputTestCase(TestCase):
def test_numeric_factor(self):
constants = self.constants
loader = self.loader
engine = SimplePipelineEngine(lambda column: loader,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column: loader, self.dates, self.asset_finder,
)
num_dates = 5
dates = self.dates[10:10 + num_dates]
high, low = USEquityPricing.high, USEquityPricing.low
@@ -338,8 +343,9 @@ class ConstantInputTestCase(TestCase):
dates=self.dates,
assets=self.assets,
)
engine = SimplePipelineEngine(lambda column: loader,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column: loader, self.dates, self.asset_finder,
)
sumdiff = RollingSumDifference()
@@ -401,10 +407,11 @@ class ConstantInputTestCase(TestCase):
dates=self.dates,
assets=self.assets)
engine = SimplePipelineEngine(lambda column: loader2
if column.dataset == Loader2DataSet
else loader1,
self.dates, self.asset_finder)
engine = SimplePipelineEngine(
lambda column:
loader2 if column.dataset == Loader2DataSet else loader1,
self.dates, self.asset_finder,
)
pipe_col1 = RollingSumSum(inputs=[Loader1DataSet1.col1,
Loader1DataSet2.col1,