@@ -93,40 +93,23 @@ def mkdir_temp(temp_dir_id: str = None) -> Path:
93
93
94
94
class FileStoreResource (ConfigurableResource ):
95
95
"""Location of the data files that are generated in the pipeline.
96
- Either local directory or a docker volume.
97
- If neither `data_dir` nor `docker_volume` is given, a local
98
- temporary directory is created.
99
- If both `data_dir` and `dir_id` are input then a new folder is created within
100
- the `data_dir`, with the name "release_<dir_id>"
96
+ data_dir: The directory where the files are stored.
97
+ If None, the resource is initialized with a temporary directory.
101
98
102
99
TODO: make the directory functions in .core (bag3d_export_dir etc) members of this
103
100
"""
104
101
105
102
data_dir : Optional [str ] = None
106
- docker_volume_id : Optional [str ] = None
107
- dir_id : Optional [str ] = None
108
103
109
104
def __init__ (
110
105
self ,
111
106
data_dir : Optional [Union [Path , str ]] = None ,
112
- docker_volume_id : Optional [str ] = None ,
113
- dir_id : Optional [str ] = None ,
114
107
):
115
- super ().__init__ (
116
- data_dir = str (data_dir ) if data_dir else None ,
117
- docker_volume_id = docker_volume_id ,
118
- dir_id = dir_id ,
119
- )
108
+ super ().__init__ (data_dir = str (data_dir ) if data_dir else None )
120
109
121
110
@property
122
111
def file_store (self ) -> FileStore :
123
- if self .data_dir and self .dir_id :
124
- return FileStore (data_dir = self .data_dir , dir_id = self .dir_id )
125
- elif self .data_dir :
112
+ if self .data_dir :
126
113
return FileStore (data_dir = self .data_dir )
127
- elif self .docker_volume_id :
128
- return FileStore (docker_volume_id = self .docker_volume_id )
129
- elif self .dir_id :
130
- return FileStore (dir_id = self .dir_id )
131
114
else :
132
115
return FileStore ()
0 commit comments