Skip to content

Commit

Permalink
Update spark example (#1713)
Browse files Browse the repository at this point in the history
Signed-off-by: Kevin Su <[email protected]>
  • Loading branch information
pingsutw authored Jul 24, 2024
1 parent 91c6c80 commit 99d0780
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion examples/k8s_spark_plugin/k8s_spark_plugin/pyspark_pi.py
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ def print_every_time(value_to_print: float, date_triggered: datetime.datetime) -
# Remember, Spark and non-Spark tasks can be chained together as long as their parameter specifications match.
# %%
@workflow
def my_spark(triggered_date: datetime.datetime = datetime.datetime.now()) -> float:
def my_spark(triggered_date: datetime.datetime = datetime.datetime(2020, 9, 11)) -> float:
"""
Using the workflow is still as any other workflow. As image is a property of the task, the workflow does not care
about how the image is configured.
Expand Down

0 comments on commit 99d0780

Please sign in to comment.