flake8

theano/gof/graph.py

@@ -1449,6 +1449,7 @@ def is_in_ancestors(l_node, f_node):
 @contextlib.contextmanager
 def nodes_constructed():
     new_nodes = []
+
     def observer(node):
         new_nodes.append(node)
     Variable.append_construction_observer(observer)

theano/gpuarray/opt.py

@@ -260,7 +260,9 @@ def op_lifter(OP, cuda_only=False):
                         to_cpu_fn = safe_to_cpu
                     else:  # suppose it is a variable on the GPU
                         new_outputs = [new_op]
-                        to_cpu_fn = lambda x: x.transfer('cpu')
+
+                        def to_cpu_fn(x):
+                            return x.transfer('cpu')
                     # copy stack traces onto gpu outputs
                     # also copy the stack traces onto HostFromGpu outputs
                     for old_output, new_output in zip(node.outputs, new_outputs):
@@ -673,8 +675,8 @@ def local_gpua_alloc_empty_to_zeros(node):
         context_name = infer_context_name(*node.inputs)
         z = np.asarray(0, dtype=node.outputs[0].dtype)
         with inherit_stack_trace(node.outputs):
-            return [GpuAlloc(context_name)(as_gpuarray_variable(z, context_name),
-                                            *node.inputs)]
+            return [GpuAlloc(context_name)(
+                as_gpuarray_variable(z, context_name), *node.inputs)]
 optdb.register('local_gpua_alloc_empty_to_zeros',
                theano.tensor.opt.in2out(local_gpua_alloc_empty_to_zeros),
                # After move to gpu and merge2, before inplace.

theano/gpuarray/tests/test_opt.py

@@ -31,7 +31,7 @@ from theano.gpuarray import dnn, blas
 def _check_stack_trace(thing):
     def _ops_to_check(op):
         if not isinstance(op, theano.gof.Op):
-            op = op.op # assume node
+            op = op.op  # assume node
         return not isinstance(op, (theano.compile.ops.Shape_i,
                                    theano.compile.ops.Shape,
                                    theano.compile.ops.DeepCopyOp,
@@ -49,6 +49,7 @@ def _check_stack_trace(thing):
     return check_stack_trace(thing, ops_to_check=_ops_to_check,
                              bug_print="ignore")
 
+
 def test_local_assert():
     x = theano.tensor.fmatrix()
     a = theano.tensor.opt.assert_op(x, theano.tensor.eq(x, 0).any())
@@ -282,6 +283,7 @@ def test_rebroadcast():
     assert isinstance(rebr.outputs[0].type, GpuArrayType)
     assert _check_stack_trace(f)
 
+
 class TestSpecifyShape(test_basic.TestSpecifyShape):
     mode = mode_with_gpu
     input_type = GpuArrayType