We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1992819 commit d1ad635Copy full SHA for d1ad635
src/dagster_dags/resources/parquet_io_manager.py
@@ -3,11 +3,12 @@
3
import datetime as dt
4
import os
5
import re
6
+import sys
7
+import tempfile
8
from typing import override
9
10
import dagster as dg
11
import pandas as pd
-from dagster._seven.temp_dir import get_system_temp_directory
12
13
14
class PartitionedParquetIOManager(dg.ConfigurableIOManager):
@@ -111,7 +112,7 @@ def _get_path(
111
112
class LocalPartitionedParquetIOManager(PartitionedParquetIOManager):
113
"""IOManager for storing Pandas DataFrames in parquet locally."""
114
- base_path: str = get_system_temp_directory()
115
+ base_path: str = tempfile.gettempdir() if sys.platform == "win32" else "/tmp" # noqa
116
117
@property
118
def _base_path(self) -> str:
0 commit comments