https://prefect.io logo
Join Slack
Powered by
Hi Prefect Experts - Im looking for a little guida...
# prefect-community
b
Hi Prefect Experts - Im looking for a little guidance on using the 
ExecuteNotebook
Task.
I have a really basic test flow that is something like:
Copy code
from prefect.tasks.jupyter.jupyter import ExecuteNotebook
execute_jupyter_notebook_task = ExecuteNotebook(output_format="json", log_output=True, path="<s3://bucket/dir/dir/dir/hello_world.ipynb>")
execute_jupyter_notebook_task()
k
What is the question? Are you trying to use it outside a Flow?
b
Im using it inside a flow, but I just wanted to really strip it down.
I can't seem to get any logs and it doesn't actually seem to be running.
k
Ah I see. Are you sure you can pass an s3 path?
b
The docs say:
Copy code
path (string, optional): path to fetch the notebook from. Can be a cloud storage path. Can also be provided post-initialization by calling this task instance
My notebook only contains this:
Copy code
import logging
import boto3

logger = logging.getLogger("papermill")
print("Hello World!")
<http://logger.info|logger.info>("Hello World!")

client = boto3.client("s3")
client.put_object(Bucket="Bucket", Key="path/output.txt"), Body="Success")
k
I don’t have any better suggestion except to try the papermill code under the hood and see if it works here
b
Thanks! I searched the slack here and the internet and wasn't able to find much.
k
Not a ton of people use this but I wrote the tests for this before and I think it works on local notebooks for sure
b
I did see your name on https://github.com/PrefectHQ/prefect/issues/4265 and the linked/merged PR
k
Yes…that was my first or second week here. Let’s not put that much faith in me either 😅. Would not be surprised if a papermill upgrade caused issues, but I never tested on S3
b
I will report back with my findings. It might take a day.
👍 1
k
Thank you!
b
The followup on this was multi-pronged. • We are using sparkmagic and the first thing that happens when a cell is executed is that sparkmagic attempts to create a sparkcontext. The task was reporting success even though when the logs were retrieved from the kubernetes job pod it showed the actual error message. • I overlooked the instructions in the PR and didn't enable the 
paepermill
logger via prefect. • fixing the sparkcontext issues and enabling the logger via the env variable 
PREFECT__LOGGING__EXTRA_LOGGERS
corrected my issues
7 Views
Open in Slack
PreviousNext
Powered by