diff --git a/import-automation/executor/app/configs.py b/import-automation/executor/app/configs.py index ee2ebdf3d..62a6bfb60 100644 --- a/import-automation/executor/app/configs.py +++ b/import-automation/executor/app/configs.py @@ -107,6 +107,8 @@ class ExecutorConfig: requirements_filename: str = 'requirements.txt' # ID of the location where Cloud Scheduler is hosted. scheduler_location: str = 'us-central1' + # Location of the local git data repo. + local_repo_dir: str = '/workspace/data' # Maximum time a user script can run for in seconds. user_script_timeout: float = 3600 # Arguments for the user script diff --git a/import-automation/executor/app/executor/import_executor.py b/import-automation/executor/app/executor/import_executor.py index 8396f9546..5eb5da7e5 100644 --- a/import-automation/executor/app/executor/import_executor.py +++ b/import-automation/executor/app/executor/import_executor.py @@ -240,7 +240,6 @@ def _execute_imports_on_commit_helper( with tempfile.TemporaryDirectory() as tmpdir: repo_dir = self.github.download_repo( tmpdir, commit_sha, self.config.repo_download_timeout) - logging.info(f'Downloaded repo: {repo_dir}') imports_to_execute = import_target.find_imports_to_execute( diff --git a/import-automation/executor/main.py b/import-automation/executor/main.py index b64a0182b..580174882 100644 --- a/import-automation/executor/main.py +++ b/import-automation/executor/main.py @@ -31,7 +31,8 @@ def scheduled_updates(absolute_import_name: str, import_config: str): auth_access_token=config.github_auth_access_token), config=config, notifier=email_notifier.EmailNotifier(config.email_account, - config.email_token)) + config.email_token), + local_repo_dir=config.local_repo_dir) result = executor.execute_imports_on_update(absolute_import_name) logging.info(result) if result.status == 'failed':