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
ploomber.tasks.Link is not usable #1148
Comments
I think it's because when we addded |
@edublancas I will. I could use a little guidance from you, though. Locally, I've got this signature for Link: class Link(Task):
...
def __init__(self, source, product, dag, name=None):
kwargs = dict(hot_reload=dag._params.hot_reload)
self._source = type(self)._init_source(kwargs)
super().__init__(product, dag, name, None) And tasks using Link tend to look like: # Dummy task to wrap success stories exported from hubspot
- name: success-stories
source: ""
product: "{{PRODUCTS_DIR}}/success-stories.csv"
class: Link
product_class: File Which, isn't terrible but the blank I don't think I can get around the I suppose I could make any string that matches Let me know your thoughts. |
With a source attribute, ploomber.tasks.Link cannot be instantiated. Without a source, the task fails validation.
It is not currently possible to use ploomber.tasks.Link in a pipeline spec.
The text was updated successfully, but these errors were encountered: