simi commented on PR #52002:
URL: https://github.com/apache/airflow/pull/52002#issuecomment-3029396890

   @Nataneljpwd @uranusjr thanks for the review. I did another take on this. 
Now it is about to create like "root" `ObjectStoragePath` you use later in your 
dags with Path API. It is similar what's described in OSP docs today, just no 
need to specify fsspec URI and thus backing connection could be different per 
environment if passing needed extra. It can be GCP with GCS config, fs with 
file or AWS with S3 config and DAG will use it with no code change. WDYT?
   
   ```python
   storage = ObjectStoragePath.from_conn(BaseHook.get_connection("storage"))
   output = storage / "my_file.txt"
   
   with output.open("w") as destination:
       destination.write("Hello!")
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to