See you all tomorrow at 9am ET. Same bat time, same bat channel (that’s a Batman reference).

🎥 Recordings from today: Part 1 Passcode:

=!5Lq8AI

Part 2 Passcode:

T*KD9!mK

@Jeff Hale It is asking for passcode to watch the recordings, I tried one on zoom URL and it does not work

Good morning all! 🔥

Question of the morning: favorite 🌮 (in 🧵) :

Use a flow from the 103 lab • Make a deployment via interactive CLI commands • Start a worker • Run a deployment from the UI • See the flow run logs in the UI • Stretch: Create a deployment that has default parameters & override the default parameters at runtime in the UI

PS C:\Users\derick.arel\PycharmProjects\prefect_environment> prefect deploy Traceback (most recent call last): File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\cli\_utilities.py", line 41, in wrapper return fn(*args, **kwargs) File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\utilities\asyncutils.py", line 255, in coroutine_wrapper return call() File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\_internal\concurrency\calls.py", line 383, in call return self.result() File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\_internal\concurrency\calls.py", line 283, in result return self.future.result(timeout=timeout) File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\_internal\concurrency\calls.py", line 169, in result return self.__get_result() File "C:\Users\derick.arel\AppData\Local\Programs\Python\Python39\lib\concurrent\futures\_base.py", line 390, in __get_result raise self._exception File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\_internal\concurrency\calls.py", line 346, in _run_async result = await coro File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\cli\deploy.py", line 251, in deploy await _run_single_deploy( File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\client\utilities.py", line 51, in with_injected_client return await fn(*args, **kwargs) File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\cli\deploy.py", line 314, in _run_single_deploy deploy_config["entrypoint"] = await prompt_entrypoint(app.console) File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\cli\_prompts.py", line 594, in prompt_entrypoint discovered_flows = await _search_for_flow_functions() File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\deployments\base.py", line 554, in _search_for_flow_functions return [fn for file_fns in await asyncio.gather(*coros) for fn in file_fns] File "c:\users\derick.arel\pycharmprojects\prefect_course_environment_course\prefect_environment\lib\site-packages\prefect\deployments\base.py", line 470, in _find_flow_functions_in_file async with OPEN_FILE_SEMAPHORE: File "C:\Users\derick.arel\AppData\Local\Programs\Python\Python39\lib\asyncio\locks.py", line 14, in aenter await self.acquire() File "C:\Users\derick.arel\AppData\Local\Programs\Python\Python39\lib\asyncio\locks.py", line 413, in acquire await fut RuntimeError: Task <Task pending name='Task-259' coro=<_find_flow_functions_in_file() running at c\users\derick.arel\pycharmprojects\prefect course environment course\prefect environment\lib\site packages\prefect\deployments\base.py470> cb=[gather.<locals>._done_callback() at C\Users\derick.arel\AppData\Local\Programs\Python\Python39\lib\asyncio\tasks.py764]> got Future <Future pending> attached to a different loop An exception occurred.

I am still behind from yesterday. And still having basic trouble, as follows. (base) C:\Users\maurreen.skowran>prefect cloud login Access is denied.

We’ll get back together in 11 minutes - at 10am ET. Feel free to take a break until then. 🙂

I got a deployment to run! (thumbs)

Longer post on dataflow design patterns: https://www.prefect.io/guide/blog/dataflow-design-patterns/

back to the custom name question, this is how we managed to do it

Hot off the press post on using webhooks: https://medium.com/the-prefect-blog/beyond-scheduling-event-driven-flows-with-prefect-b072edd06833

Here’s a guide to creating custom flow run names: https://discourse.prefect.io/t/prefect-2-7-12-is-out-with-custom-templatable-flow-and-task-run-names/2357

I tried to deploy, but just pressed 'enter' when I was asked to name the process pool name. Now I get the following error.

105 lab: • Create a deployment that uses one of the new workflow patterns you’ve seen in this module. • See the prefect.yaml. Use GitHub or other git-repo-based code storage. ◦ Don’t forget to push your code! • Add a schedule. • Pause the schedule.

Enum params @Patrick Tan

We’ll get back together at 10:50am - in 5 minutes. 🙂

Sorry, I think I missed something. What was the point of pushing the prefect.yaml to github?

Helm chart for Prefect Kubernetes

Thank you for all your hard work! 🚀 We are always working to improve this course, so if you could take 2 minutes to share your feedback here, we’d really appreciate it!

I thought this course was great. The structure with the labs encouraged a high level of engagement. Great job Prefect team! Thank you.

clap

Since this course has the title of "Prefect Associate Certification Course" - is there a certification test or some "official" cert that comes with?

A bit more on work queues here. Book a Rubber Duck session with Bianca or Sahil to answer Prefect questions here.

Reminder to please take a few minutes to fill out this brief survey: here. 🙂 Thank you to everyone who already filled it out! 🎉

Recording from today: Link: https://us06web.zoom.us/rec/share/C4Xpf9QP_jjZJYr2VGf4zLnL6CLto4kKmkQjt7pAkh2EVH4Q_8Mxh8DM2fF7y3Vm.z-SYBNQYTgN4yj0j Passcode: *I0MyZ9W

Feel free to connect on LinkedInprefect duck

I don't remember who (apologies) but someone from this PACC asked about flow run logs not showing up when a flow run was completed until after refreshing the page. Though the answer I gave was correct in explaining how logs were refreshed on an interval, upon looking at this more closely I realized we were missing some logs in some instances! So thank you to whoever brought that up. The next oss and cloud release should include this fix for that.

archived the channel