Utility function to migrate external blob data from 0.11 to 0.12.
:param migration_schema: string of target schema to be migrated
:param store: string of target dj.config['store'] to be migrated
Source code in datajoint/migrate.py
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43 | def migrate_dj011_external_blob_storage_to_dj012(migration_schema, store):
"""
Utility function to migrate external blob data from 0.11 to 0.12.
:param migration_schema: string of target schema to be migrated
:param store: string of target dj.config['store'] to be migrated
"""
if not isinstance(migration_schema, str):
raise ValueError(
"Expected type {} for migration_schema, not {}.".format(
str, type(migration_schema)
)
)
do_migration = False
do_migration = (
user_choice(
"""
Warning: Ensure the following are completed before proceeding.
- Appropriate backups have been taken,
- Any existing DJ 0.11.X connections are suspended, and
- External config has been updated to new dj.config['stores'] structure.
Proceed?
""",
default="no",
)
== "yes"
)
if do_migration:
_migrate_dj011_blob(dj.Schema(migration_schema), store)
print(
"Migration completed for schema: {}, store: {}.".format(
migration_schema, store
)
)
return
print("No migration performed.")
|