Skip to content

Commit

Permalink
lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
jehangiramjad committed Feb 8, 2024
1 parent b655d34 commit 246a41e
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions import-automation/executor/schedule_update_import.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,10 @@
_FLAGS = flags.FLAGS

flags.DEFINE_string('mode', '', 'Options: update or schedule.')
flags.DEFINE_string('gke_project_id', '', 'GCP Project where import executor runs.')
flags.DEFINE_string('config_project_id', 'datcom-204919', 'GCS Project for the config file.')
flags.DEFINE_string('gke_project_id', '',
'GCP Project where import executor runs.')
flags.DEFINE_string('config_project_id', 'datcom-204919',
'GCS Project for the config file.')
flags.DEFINE_string('config_bucket', 'import-automation-configs',
'GCS bucket name for the config file.')
flags.DEFINE_string('config_filename', 'configs.json',
Expand Down Expand Up @@ -101,8 +103,8 @@ def _get_cloud_config(filename: str) -> Dict:
f'\nProject ID: {config_project_id}\nBucket: {bucket_name}\nConfig Filename: {filename}'
)

bucket = storage.Client(config_project_id).bucket(bucket_name,
user_project=config_project_id)
bucket = storage.Client(config_project_id).bucket(
bucket_name, user_project=config_project_id)
blob = bucket.blob(filename)
config_dict = json.loads(blob.download_as_string(client=None))
return config_dict
Expand Down

0 comments on commit 246a41e

Please sign in to comment.