• j

    John Ramirez

    2 years ago
    hey everyone - on prefect 0.9.7 and getting this error during deployment
    ModuleNotFoundError: No module named 'prefect.utilities.notifications.notifications'; 'prefect.utilities.notifications' is not a package
    j
    1 replies
    Copy to Clipboard
  • a

    Adam Roderick

    2 years ago
    I have a flow failing in cloud that runs fine locally. I suspect something is up with the secrets. I have local secrets enabled, and I simply pasted the value into cloud secrets. The error is
    Exception raised while calling state handlers: TypeError('string indices must be integers')
    . I don't really now how to begin troubleshooting this in cloud. Any ideas?
    a
    Chris White
    25 replies
    Copy to Clipboard
  • a

    alvin goh

    2 years ago
    I'm looking at using perfect scheduler.. can it run entirely offline in an enterprise environment?
    a
    Chris White
    6 replies
    Copy to Clipboard
  • n

    Nguyen Hoang Nguyen

    2 years ago
    Hi right now I want to scheldure a task with a CronClock, but right now the default CronClock of Prefect is in UTC. Is there a way to change it to a specific time zone? The code I try right now is as follow but it does not change the start date of the CronClock (terminal still show UTC)
    from prefect.schedules.clocks import CronClock
    import pendulum
    
    schedule = Schedule(clocks=[CronClock("40 14 * * *", start_date=pendulum.now("Asia/Ho_Chi_Minh"))])
    n
    Alex Goodman
    5 replies
    Copy to Clipboard
  • t

    trapped

    2 years ago
    hi guys! what would be the correct way to have an environment-global Flow (i.e. can run on all agents) with environment-specific Flow Runs (i.e. only runs on some agents depending on their labels)? from the docs it seems labels can only be set on Flows, and the
    Client.create_flow_run
    method doesn't accept a
    labels
    parameter
    t
    1 replies
    Copy to Clipboard
  • m

    Manuel Aristarán

    2 years ago
    Hey everyone. I’m wondering if anybody here has integrated Singer.io’s taps and targets with a Prefect Flow?
    m
    Laura Lorenz (she/her)
    7 replies
    Copy to Clipboard
  • j

    John Ramirez

    2 years ago
    hey everyone - im dealing with an unusual issue in dask. I need to clear memory after a workflow run (success or failure) but I can’t use
    client.restart
    in the workflow because the workflow will fail. Any thoughts or ideas on how to clear memory
    j
    Chris White
    17 replies
    Copy to Clipboard
  • w

    Wolfgang Kerzendorf

    2 years ago
    I'm trying to map a map again so the first map returns a list - then the second task makes a list of lists out of these tasks. I want the next task to directly work on the items of the list of lists. How do I do that?
    w
    Chris White
    2 replies
    Copy to Clipboard
  • m

    Manuel Aristarán

    2 years ago
    Is there a limit to the number of Parameters a
    Flow
    can have?
  • m

    Manuel Aristarán

    2 years ago
    prefect
    seems to ignore the 3rd declared Parameter:
    with Flow("Salesforce to Cassandra") as f:
        tap_config = Parameter("tap_config")
        tap_catalog = Parameter("tap_catalog")
        target_config = Parameter("target_config")
    
        salesforce_result = run_salesforce_tap(config=tap_config, catalog=tap_catalog)
        result = run_cassandra_target(config=target_config, input=salesforce_result)