@@ -337,17 +337,17 @@ def test_write_batched_display_data(self):
337337 ARROW_MAJOR_VERSION >= 13 ,
338338 'pyarrow 13.x and above does not throw ArrowInvalid error' )
339339 def test_sink_transform_int96 (self ):
340- with tempfile .NamedTemporaryFile () as dst :
341- path = dst .name
342- # pylint: disable=c-extension-no-member
343- with self .assertRaisesRegex (Exception , 'would lose data' ):
344- # Should throw an error "ArrowInvalid: Casting from timestamp[ns] to
345- # timestamp[us] would lose data"
346- with TestPipeline () as p :
347- _ = p \
348- | Create (self .RECORDS ) \
349- | WriteToParquet (
350- path , self .SCHEMA96 , num_shards = 1 , shard_name_template = '' )
340+ dst = tempfile .NamedTemporaryFile ()
341+ path = dst .name
342+ # pylint: disable=c-extension-no-member
343+ with self .assertRaisesRegex (Exception , 'would lose data' ):
344+ # Should throw an error "ArrowInvalid: Casting from timestamp[ns] to
345+ # timestamp[us] would lose data"
346+ with TestPipeline () as p :
347+ _ = p \
348+ | Create (self .RECORDS ) \
349+ | WriteToParquet (
350+ path , self .SCHEMA96 , num_shards = 1 , shard_name_template = '' )
351351
352352 def test_sink_transform (self ):
353353 with TemporaryDirectory () as tmp_dirname :
0 commit comments