Test that results of old and new form reads are the same

dagster-io · Aug 24, 2020 · f1a9b73 · f1a9b73
1 parent a1fb909
commit f1a9b73
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/python_modules/libraries/dagster-dask/dagster_dask_tests/test_data_frame.py b/python_modules/libraries/dagster-dask/dagster_dask_tests/test_data_frame.py
@@ -37,6 +37,15 @@ def return_df(_, input_df):
     assert result.success
     assert assert_eq(result.output_value(), create_dask_df())
 
+    read_result = execute_solid(
+        return_df,
+        run_config={
+            'solids': {'return_df': {'inputs': {'input_df': {'read': {file_type: {'path': file_name}}}}}}
+        },
+    )
+    assert read_result.success
+    assert assert_eq(result.output_value(), read_result.output_value())
+
 
 @pytest.mark.parametrize(
     'file_type,read,kwargs',