Skip to content

Conversation

@bolkedebruin
Copy link
Contributor

@bolkedebruin bolkedebruin commented Oct 28, 2023

This add the pyspark decorator so that spark can be run inline so that results, like dataframes, can be shared. The spark context gets injected into the python callable.

This add the pysprak decorator so that spark can be
run inline so that results, like dataframes, can be
shared.
@bolkedebruin
Copy link
Contributor Author

@eladkal PTAL.

@bolkedebruin bolkedebruin requested a review from eladkal October 30, 2023 17:53
@bolkedebruin
Copy link
Contributor Author

cc @hussein-awala if you have some time PTAL

Copy link
Member

@hussein-awala hussein-awala left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It looks good, LGTM!

@hussein-awala
Copy link
Member

Merge main to check if the tests pass after Jarek PR.

@hussein-awala
Copy link
Member

Could you add @pytest.mark.db_test before the failed tests?

@bolkedebruin bolkedebruin merged commit 0a4ed7d into apache:main Nov 1, 2023
@bolkedebruin bolkedebruin deleted the pyspark_task branch November 1, 2023 10:43
romsharon98 pushed a commit to romsharon98/airflow that referenced this pull request Nov 10, 2023
This add the pyspark decorator so that spark can be
run inline so that results, like dataframes, can be
shared.
@ephraimbuddy ephraimbuddy added the type:new-feature Changelog: New Features label Nov 19, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants