-
Notifications
You must be signed in to change notification settings - Fork 4
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[#47] Adding filesystem support for save_df #48
base: main
Are you sure you want to change the base?
Conversation
d47af0c
to
11c3f24
Compare
raydar/task_tracker/task_tracker.py
Outdated
path: Optional[str] = None, | ||
enable_perspective_dashboard: bool = False, | ||
): | ||
def __init__(self, name: str, namespace: str, enable_perspective_dashboard: bool = False, filesystem: Type[fs.FileSystem] = fs.LocalFileSystem): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should this take an instance, otherwise how would you pass args to e.g. fs.S3FileSystem
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
\we've seen some issues with serializing certain filesystem objects - the alternative is default construction of a filesystem, which you can toggle through env variables. We could probably just take like a filesystem_kwargs=dict() parameter too, I don't have strong feelings about this
032e423
to
0558819
Compare
... Signed-off-by: Todd Gaugler <[email protected]> ... ... . ...
Responding to some requests to allow for better
save_df
functionality, specifically saving the internal dataframe to cloud storage rather than saving to local path.I'll play around with this approach and write some tests.
fixes #47