Create the appropriate metadata store.
(options: Options, parallel_worker: bool)
| 1911 | |
| 1912 | |
| 1913 | def create_metastore(options: Options, parallel_worker: bool) -> MetadataStore: |
| 1914 | """Create the appropriate metadata store.""" |
| 1915 | if options.sqlite_cache: |
| 1916 | mds: MetadataStore = SqliteMetadataStore( |
| 1917 | _cache_dir_prefix(options), |
| 1918 | set_journal_mode=not parallel_worker, |
| 1919 | num_shards=options.sqlite_num_shards, |
| 1920 | ) |
| 1921 | else: |
| 1922 | mds = FilesystemMetadataStore(_cache_dir_prefix(options)) |
| 1923 | return mds |
| 1924 | |
| 1925 | |
| 1926 | def get_meta_ex_name(meta_name: str) -> str: |
no test coverage detected
searching dependent graphs…