Background Tasks / Progress

Execute background functions while incrementing a progress bar.

import time
import asyncio
import concurrent.futures
from h2o_wave import main, app, Q, ui
# A long-running that performs a blocking operation, in this case time.sleep()
def blocking_function(secs) -> str:
time.sleep(secs) # Blocks!
return 'Download completed!'
# An async function that displays a progress bar
async def display_progress_bar(q: Q, form, seconds: int):
for i in range(seconds):
progress_value = (i + 1.0) / seconds
form.items = [
label='Downloading the interwebs...',
caption=f'{int(progress_value * 100)}%',
await q.sleep(1)
async def serve(q: Q):
if q.args.start: # The button named 'start' was clicked
seconds = 5
# Grab a reference to the form
form =['form']
# Start incrementing the progress bar in the background
future = asyncio.ensure_future(display_progress_bar(q, form, seconds))
# Execute our long-running function in the background
with concurrent.futures.ThreadPoolExecutor() as pool:
message = await q.exec(pool, blocking_function, seconds)
# Stop the progress bar (optional unless we used a infinite while loop in display_progress_bar()).
# At this point, we're done with the long-running function; so display a completion message
form.items = [ui.message_bar('info', message)]
else:['form'] = ui.form_card(box='1 1 12 10', items=[ui.button(name='start', label='Start')])

Tags: โ€‚background_tasks โ€‚progress