Hi there I have a Redis kv store set up and running and I wo Prefect Community #ask-community

Hi there, I have a Redis kv store set up and runni...

Blake List

08/24/2021, 11:33 PM

Hi there, I have a Redis kv store set up and running, and I would like to set and get values for timestamps using the conditional ifelse task. I am running into some troubles when trying to get the False case:

Copy code

import time
import prefect
from prefect import task, Flow
from prefect.tasks.redis import RedisSet, RedisGet
from prefect.tasks.control_flow import ifelse

redis_get = RedisGet(...)
redis_set = RedisSet(...)

with Flow("flow_p") as flow:
    t1_get = redis_get(redis_key='t1_key')

    # true case
    t1_init = redis_set(redis_key='t1_key', redis_val="0000-00-00 00:00:00")
    # false case
    t1_set = redis_set(redis_key='t1_key', redis_val=time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))
    
    ifelse(case(t1_get, None), t1_init, t1_set)

flow.run()

Running once then doing

Copy code

RedisGet(...).run(redis_key='t1_key')

gives

Copy code

b'0000-00-00 00:00:00'

but running again gives the same value. Any ideas why I am not getting the False case on the second run?

Kevin Kho

08/25/2021, 12:39 AM

I suspect the

case

might have a different usage. Can you try replacing

case(t1_get, None)

task(lambda x: (x == None))(t1_get)

Blake List

08/25/2021, 12:43 AM

It works!!! Thank you so very much 😁

Blake List

08/25/2021, 2:00 AM

Just a follow up question: is it possible to set a trigger for a task to be the success of another task (even if that task is not upstream directly)? i.e. in the flow

Copy code

with Flow("flow_p") as flow:
    t1_get = redis_get(redis_key='t1_key')
    t2_get = redis_get(redis_key='t2_key')
    
    t1_init = redis_set(redis_key='t1_key', redis_val="0000-00-00 00:00:00")
    t1_set = redis_set(redis_key='t1_key', redis_val=t2_get)
    
    ifelse(task(lambda x: (x == None))(t1_get), t1_init, t1_set)

    redis_set(redis_key='t2_key', redis_val=time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))

I need

Copy code

redis_set(redis_key='t2_key', redis_val=time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))

to wait for

Copy code

ifelse(task(lambda x: (x == None))(t1_get), t1_init, t1_set)

to run.

Kevin Kho

08/25/2021, 3:24 AM

Check this for the syntax

Blake List

08/25/2021, 4:35 AM

Hi @Kevin Kho, my issue is that t2 is not updating after the second run. Both values are initially set ok on the first run, and t1 takes t2's value on the second run, but t2 does not update. See below. Any ideas why?

Copy code

with Flow("flow_p") as flow:
    t1_get = redis_get(redis_key='t1_key')
    t2_get = redis_get(redis_key='t2_key')
    
    t1_init = redis_set(redis_key='t1_key', redis_val="0000-00-00 00:00:00")
    t1_set = redis_set(redis_key='t1_key', redis_val=t2_get)
    
    cond = ifelse(task(lambda x: (x == None))(t1_get), t1_init, t1_set)

    redis_set(redis_key='t2_key', redis_val=time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()), upstream_tasks=[cond])

###############################

print(RedisGet(host=myhost).run(redis_key='t1_key'))
print(RedisGet(host=myhost).run(redis_key='t2_key'))

flow.run()

print(RedisGet(host=myhost).run(redis_key='t1_key'))
print(RedisGet(host=myhost).run(redis_key='t2_key'))

flow.run()

print(RedisGet(host=myhost).run(redis_key='t1_key'))
print(RedisGet(host=myhost).run(redis_key='t2_key'))

With output:

Copy code

None
None
[2021-08-25 16:34:13+1200] INFO - prefect.FlowRunner | Beginning Flow run for 'flow_p'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task '<lambda>': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task '<lambda>': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'as_bool': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'as_bool': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "True" did not match "False"')
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Finished task run for task with final state: 'Skipped'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Skipped'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
b'0000-00-00 00:00:00'
b'2021-08-25 16:31:41'
[2021-08-25 16:34:13+1200] INFO - prefect.FlowRunner | Beginning Flow run for 'flow_p'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task '<lambda>': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task '<lambda>': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'as_bool': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'as_bool': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "False" did not match "True"')
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Finished task run for task with final state: 'Skipped'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Skipped'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 16:34:13+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 16:34:13+1200] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
b'2021-08-25 16:31:41'
b'2021-08-25 16:31:41'

Kevin Kho

08/25/2021, 4:54 AM

I think when the

CompareValue

is False in your graph, it raises a

SKIP

which makes the downstream task

SKIP

as well. I think you need to do

ResetSet(…, skip_on_upstream_skip=False)

when you initialize it.

Blake List

08/25/2021, 5:31 AM

The CompareValue corresponds to the ifelse task which is setting t1_key. I think this matches up with the the log output. I'm just not sure why t2_key is the same as before on the second run. Adding

skip_on_upstream_skip=False

to RedisSet yields:

Copy code

None
None
[2021-08-25 17:29:44+1200] INFO - prefect.FlowRunner | Beginning Flow run for 'flow_p'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task '<lambda>': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task '<lambda>': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'as_bool': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'as_bool': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "True" did not match "False"')
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Finished task run for task with final state: 'Skipped'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 17:29:44+1200] ERROR - prefect.TaskRunner | Task 'RedisSet': Exception encountered during task execution!
Traceback (most recent call last):
  File "/workspace/appscratch/miniconda/cflbwl_black/lib/python3.7/site-packages/prefect/engine/task_runner.py", line 863, in get_task_run_state
    logger=self.logger,
  File "/workspace/appscratch/miniconda/cflbwl_black/lib/python3.7/site-packages/prefect/utilities/executors.py", line 445, in run_task_with_timeout
    return task.run(*args, **kwargs)  # type: ignore
  File "/workspace/appscratch/miniconda/cflbwl_black/lib/python3.7/site-packages/prefect/utilities/tasks.py", line 441, in method
    return run_method(self, *args, **kwargs)
  File "/workspace/appscratch/miniconda/cflbwl_black/lib/python3.7/site-packages/prefect/tasks/redis/redis_tasks.py", line 101, in run
    raise ValueError("redis_key and redis_val must be provided")
ValueError: redis_key and redis_val must be provided
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Failed'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.FlowRunner | Flow run FAILED: some reference tasks failed.
b'0000-00-00 00:00:00'
b'2021-08-25 17:29:42'
[2021-08-25 17:29:44+1200] INFO - prefect.FlowRunner | Beginning Flow run for 'flow_p'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task '<lambda>': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task '<lambda>': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'as_bool': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'as_bool': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "False" did not match "True"')
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Finished task run for task with final state: 'Skipped'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-25 17:29:44+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-25 17:29:44+1200] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
b'2021-08-25 17:29:42'
b'2021-08-25 17:29:42'

Kevin Kho

08/25/2021, 3:07 PM

Maybe this might be easier without the

ifelse

and instead switching to

case

Kevin Kho

08/25/2021, 3:08 PM

Copy code

with Flow("flow_p") as flow:
    t1_get = redis_get(redis_key='t1_key')
    t2_get = redis_get(redis_key='t2_key')
    
    t1_init = redis_set(redis_key='t1_key', redis_val="0000-00-00 00:00:00")
    t1_set = redis_set(redis_key='t1_key', redis_val=t2_get)
    
    cond = task(lambda x: (x == None))(t1_get)
    with case(cond, true):
         .....

    with case(cond, false):
         redis_set(redis_key='t2_key', redis_val=time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()), upstream_tasks=[cond])

Kevin Kho

08/25/2021, 3:08 PM

this will make it go under the case and the syntax might be easier?

Blake List

08/25/2021, 9:50 PM

Hi @Kevin Kho, the t2_key needs to be set to the current time regardless of the condition. So it shouldn't be in a case task block. The issue is that doesn't seem to update the value on the second run. It does on the first (initialising t1 to 0000 and t2 to time.now())

Blake List

08/25/2021, 10:33 PM

I have fixed it!!! Adding a task to get the current time and passing this to redis_set for t2_key produces the desired behaviour. Full code and output below.

Copy code

import time
import prefect
from prefect import task, Flow
from prefect.tasks.redis import RedisSet, RedisGet, RedisExecute
from prefect.tasks.control_flow import ifelse

redis_get = RedisGet(host=myhost) # password is set as an env variable.
redis_set = RedisSet(host=myhost) # notice that skip_on_upstream_skip=False is not used.

@task
def get_current_time():
    logger = prefect.context.get("logger")
    time_now = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
    <http://logger.info|logger.info>(f"Current time: {time_now}")
    return time_now

with Flow("flow_p") as flow:
    t1_get = redis_get(redis_key='t1_key')
    t2_get = redis_get(redis_key='t2_key')
    
    t1_init = redis_set(redis_key='t1_key', redis_val="0000-00-00 00:00:00")
    t1_set = redis_set(redis_key='t1_key', redis_val=t2_get)
    
    cond = ifelse(task(lambda x: (x == None))(t1_get), t1_init, t1_set)

    # cond is passed as an upstream task to ensure it runs after. note that it is
    # not needed for success if testing locally.
    redis_set(redis_key='t2_key', redis_val=get_current_time, upstream_tasks=[cond])

print(RedisGet(host=myhost).run(redis_key='t1_key'))
print(RedisGet(host=myhost).run(redis_key='t2_key'))

flow.run()

print(RedisGet(host=myhost).run(redis_key='t1_key'))
print(RedisGet(host=myhost).run(redis_key='t2_key'))

time.sleep(10)

flow.run()

print(RedisGet(host=myhost).run(redis_key='t1_key'))
print(RedisGet(host=myhost).run(redis_key='t2_key'))

output:

Copy code

None
None
[2021-08-26 10:29:15+1200] INFO - prefect.FlowRunner | Beginning Flow run for 'flow_p'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task '<lambda>': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task '<lambda>': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'as_bool': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'as_bool': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "True" did not match "False"')
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Finished task run for task with final state: 'Skipped'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'get_current_time': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.get_current_time | Current time: 2021-08-26 10:29:15
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'get_current_time': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Skipped'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-26 10:29:15+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:15+1200] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
b'0000-00-00 00:00:00'
b'2021-08-26 10:29:15'
[2021-08-26 10:29:25+1200] INFO - prefect.FlowRunner | Beginning Flow run for 'flow_p'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task '<lambda>': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task '<lambda>': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisGet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'as_bool': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'as_bool': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | SKIP signal raised: SKIP('Provided value "False" did not match "True"')
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "True"': Finished task run for task with final state: 'Skipped'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'get_current_time': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.get_current_time | Current time: 2021-08-26 10:29:25
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'get_current_time': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Skipped'
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Starting task run...
[2021-08-26 10:29:25+1200] INFO - prefect.TaskRunner | Task 'RedisSet': Finished task run for task with final state: 'Success'
[2021-08-26 10:29:25+1200] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded
b'2021-08-26 10:29:15'
b'2021-08-26 10:29:25'

Thank you very much for all your help! 😁

Kevin Kho

08/26/2021, 12:46 AM

Oh I see. Thanks for letting me know!

2 Views

Open in Slack

Previous Next