Rajan Subramanian
03/02/2022, 4:22 PMAnna Geller
03/02/2022, 4:26 PMfrom prefect import task
import subprocess
@task
def run_shell_command(cmd: str):
subprocess.run(cmd, shell=True)
Rajan Subramanian
03/02/2022, 4:55 PMKevin Kho
03/02/2022, 5:46 PMAnna Geller
03/02/2022, 5:48 PMShellTask
@task
def write_real_time_data():
for iteration in range(1, 7):
<http://logger.info|logger.info>("iteration nr %s", iteration)
read_from_redis_and_load_to_postgres() # your logic here
if iteration < 6:
<http://logger.info|logger.info>("Sleeping for 10 seconds...")
time.sleep(10)
Rajan Subramanian
03/02/2022, 6:37 PMKevin Kho
03/10/2022, 8:10 PMRajan Subramanian
03/10/2022, 8:22 PMKevin Kho
03/11/2022, 4:13 AMRajan Subramanian
03/19/2022, 5:12 PMKevin Kho
03/19/2022, 5:15 PMprefect agent start uuid
on a VM that contains Prefect Orion?Rajan Subramanian
03/19/2022, 5:15 PMKevin Kho
03/19/2022, 5:15 PMRajan Subramanian
03/19/2022, 5:15 PMKevin Kho
03/19/2022, 5:16 PMRajan Subramanian
03/19/2022, 5:17 PMKevin Kho
03/19/2022, 5:18 PMRajan Subramanian
03/19/2022, 5:18 PMKevin Kho
03/19/2022, 5:23 PMRajan Subramanian
03/19/2022, 5:23 PMKevin Kho
03/19/2022, 5:23 PMRajan Subramanian
03/19/2022, 5:24 PMKevin Kho
03/19/2022, 5:25 PMRajan Subramanian
03/19/2022, 5:26 PMKevin Kho
03/19/2022, 5:27 PMRajan Subramanian
03/19/2022, 5:27 PMKevin Kho
03/19/2022, 5:27 PMRajan Subramanian
03/19/2022, 5:27 PMKevin Kho
03/19/2022, 5:28 PMRajan Subramanian
03/19/2022, 5:28 PMKevin Kho
03/19/2022, 5:28 PMRajan Subramanian
03/19/2022, 5:29 PMKevin Kho
03/19/2022, 5:34 PMRajan Subramanian
03/19/2022, 6:03 PMKevin Kho
03/19/2022, 9:43 PM