tyrel/celigo
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

actually make the real directory, not just ones in tests

Browse Source
This commit is contained in:
Tyrel Souza 2016-05-25 13:07:23 -04:00
parent ec720e7ff4
commit ac188f42f5
No known key found for this signature in database
GPG Key ID: 2EECB5087209E6A5
1 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
celigo/core.py
View File

@ -80,10 +80,8 @@ class BackupCeligo(object):
def ensure_directories_exist(self, subdirs=None): def ensure_directories_exist(self, subdirs=None):
""" Make the directory if it doesn't exist """ """ Make the directory if it doesn't exist """
if not subdirs:
subdirs = ('integrations', 'connections')
for subdir in subdirs: for subdir in subdirs:
L.info("Creating subdir: `%s`", subdir)
_dir = os.path.join(self.data_dir, subdir) _dir = os.path.join(self.data_dir, subdir)
if not os.path.exists(_dir): if not os.path.exists(_dir):
os.makedirs(_dir) os.makedirs(_dir)
@ -147,12 +145,6 @@ class BackupCeligo(object):
L.info("Got all imports, writing now") L.info("Got all imports, writing now")
for integration_id, integration in self.imports_cache.items(): for integration_id, integration in self.imports_cache.items():
# Make sure the integration directories exist
base = "integrations/"+integration_id
subdirs = (base + "imports", base + "exports")
self.ensure_directories_exist(subdirs=subdirs)
# save the files
for flow in integration['flows']: for flow in integration['flows']:
self.save_flow(integration_id, flow, auto) self.save_flow(integration_id, flow, auto)
@ -190,6 +182,7 @@ class BackupCeligo(object):
self.restore_to_celigo(action) self.restore_to_celigo(action)
del self.imports_cache[action] del self.imports_cache[action]
def cache_import_remote(self, flow): def cache_import_remote(self, flow):
""" """
Stores the import in self.imports_cache before write. Stores the import in self.imports_cache before write.
@ -198,7 +191,8 @@ class BackupCeligo(object):
import_id = flow['_importId'] import_id = flow['_importId']
integration_id = flow['_integrationId'] integration_id = flow['_integrationId']
import_conf = self._celigo_api_get( import_conf = self._celigo_api_get(
"imports/{id}/distributed".format(id=import_id)) "imports/{id}/distributed".format(
id=import_id))
self.imports_cache[integration_id]['flows'].append({ self.imports_cache[integration_id]['flows'].append({
"name": flow_name, "name": flow_name,
@ -218,10 +212,15 @@ class BackupCeligo(object):
flow_id = flow['id'] flow_id = flow['id']
flow_conf = flow['configuration'] flow_conf = flow['configuration']
filename = os.path.join(self.data_dir, filedir = os.path.join(self.data_dir,
"integrations", "integrations",
integration_id, integration_id,
"imports", "imports")
self.ensure_directories_exist((filedir,))
filename = os.path.join(
filedir,
"%s_%s.json" % (slugify(flow_name), flow_id)) "%s_%s.json" % (slugify(flow_name), flow_id))
write = True write = True