-
Notifications
You must be signed in to change notification settings - Fork 1.7k
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
BigQueryTask #678
BigQueryTask #678
Conversation
## check for any argument inconsistencies | ||
if query is None: | ||
raise ValueError("No query provided.") | ||
if sum([dataset_dest is None, table_dest is None]) == 1: |
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.
:mind blown:
def __init__( | ||
self, | ||
query: str = None, | ||
query_params: List[tuple] = None, # 3-tuples |
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.
Looks like this arg is unused
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.
Good eye; used now.
@cicdw looking good. What do you think about linking to these docs in the arg docstring for |
@jlowin updated 👍 |
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.
🚀
Thanks for contributing to Prefect!
Please describe your work and make sure your PR:
CHANGELOG.md
(if appropriate)docs/outline.toml
for API reference docs (if appropriate)What does this PR change and why is it important?
Adds a
BigQueryTask
to the task library and adds an additional google package dependency. At some point we will need to discuss the correct way to handle our packages with testing + documentation.