tests/operators/test_agnostic_save_file.py
def _s3fs_creds():
        # To-do: reuse this method from sql decorator
        """Structure s3fs credentials from Airflow connection.
        s3fs enables pandas to write to s3
        """
        # To-do: clean-up how S3 creds are passed to s3fs

        return {
            "key": os.environ["AWS_ACCESS_KEY_ID"],
            "secret": os.environ["AWS_SECRET_ACCESS_KEY"],
        }
Structure s3fs credentials from Airflow connection.
        s3fs enables pandas to write to s3
        
Structure s3fs credentials from Airflow connection.
s3fs enables pandas to write to s3
Structure s3fs credentials from Airflow connection . s3fs enables pandas to write to s3
def _s3fs_creds():
        return {
            "key": os.environ["AWS_ACCESS_KEY_ID"],
            "secret": os.environ["AWS_SECRET_ACCESS_KEY"],
        }
def _s3fs_creds ( ) : return { "key" : os . environ [ "AWS_ACCESS_KEY_ID" ] , "secret" : os . environ [ "AWS_SECRET_ACCESS_KEY" ] , }
Structure s3fs credentials from Airflow connection.
Structure s3fs credentials from Airflow connection .
# To-do: reuse this method from sql decorator """Structure s3fs credentials from Airflow connection.
        s3fs enables pandas to write to s3
        """ # To-do: clean-up how S3 creds are passed to s3fs