Skip to content

Commit

Permalink
Remove prints
Browse files Browse the repository at this point in the history
  • Loading branch information
pankajkoti committed Dec 27, 2024
1 parent b447104 commit 12f0a24
Showing 1 changed file with 0 additions and 19 deletions.
19 changes: 0 additions & 19 deletions cosmos/operators/local.py
Original file line number Diff line number Diff line change
Expand Up @@ -503,19 +503,9 @@ def run_command(
self.store_freshness_json(tmp_project_dir, context)
self.store_compiled_sql(tmp_project_dir, context)
self.upload_compiled_sql(tmp_project_dir, context)
print("Result is", result)
dirlist = os.listdir(tmp_project_dir)
print("Before: Files and directories in '", tmp_project_dir, "' :")
print("\t", dirlist)
if self.callback:
dirlist = os.listdir(f"{tmp_project_dir}/target")
print("Before: Files and directories in '", tmp_project_dir, "' :")
print("\t", dirlist)
self.callback_args.update({"context": context})
self.callback(tmp_project_dir, **self.callback_args)
dirlist = os.listdir(f"{tmp_project_dir}/target")
print("After: Files and directories in '", tmp_project_dir, "' :")
print("\t", dirlist)
self.handle_exception(result)

return result
Expand Down Expand Up @@ -909,9 +899,6 @@ def upload_to_cloud_storage(self, project_dir: str, **kwargs: Any) -> None:
'Attempting to upload generated docs to S3 using S3Hook("%s")',
self.connection_id,
)
dirlist = os.listdir(f"{project_dir}/target")
print("Files and directories in '", project_dir, "' :")
print("\t", dirlist)

from airflow.providers.amazon.aws.hooks.s3 import S3Hook

Expand Down Expand Up @@ -978,9 +965,6 @@ def upload_to_cloud_storage(self, project_dir: str, **kwargs: Any) -> None:
'Attempting to upload generated docs to Azure Blob Storage using WasbHook(conn_id="%s")',
self.connection_id,
)
dirlist = os.listdir(f"{project_dir}/target")
print("Files and directories in '", project_dir, "' :")
print("\t", dirlist)

from airflow.providers.microsoft.azure.hooks.wasb import WasbHook

Expand Down Expand Up @@ -1025,9 +1009,6 @@ def upload_to_cloud_storage(self, project_dir: str, **kwargs: Any) -> None:
'Attempting to upload generated docs to Storage using GCSHook(conn_id="%s")',
self.connection_id,
)
dirlist = os.listdir(f"{project_dir}/target")
print("Files and directories in '", project_dir, "' :")
print("\t", dirlist)

from airflow.providers.google.cloud.hooks.gcs import GCSHook

Expand Down

0 comments on commit 12f0a24

Please sign in to comment.