• Ishavpreet Singh

    Ishavpreet Singh

    1 year ago
    seems the auth_token is getting loaded into int type variable
  • Ishavpreet Singh

    Ishavpreet Singh

    1 year ago
    Traceback (most recent call last):  File "/usr/local/lib/python3.9/site-packages/toml/decoder.py", line 511, in loads   ret = decoder.load_line(line, currentlevel, multikey,  File "/usr/local/lib/python3.9/site-packages/toml/decoder.py", line 778, in load_line   value, vtype = self.load_value(pair[1], strictly_valid)  File "/usr/local/lib/python3.9/site-packages/toml/decoder.py", line 918, in load_value   v = int(v, 0) ValueError: invalid literal for int() with base 0
    Ishavpreet Singh
    Michael Adkins
    10 replies
    Copy to Clipboard
  • William Burdett

    William Burdett

    1 year ago
    Is it possible to tell a flow to not run if it is already running?
    William Burdett
    Bouke Krom
    +1
    4 replies
    Copy to Clipboard
  • Matthias Roels

    Matthias Roels

    1 year ago
    I recently had to work with kedro, an open-source Python framework for creating modular workflows. Even though I am not a 100% fan of the framework, there are several features I really like. One of which is how they handle the concept of a flow of flows (which they call modular pipelines). Hence the reason I am posting it here, mainly because I thought it could serve as inspiration for additional features in Prefect...
    Matthias Roels
    1 replies
    Copy to Clipboard
  • Michael

    Michael

    1 year ago
    Hey there! Is there anything equivalent to
    prefect get
    (api here) in the Python client? In particular, is there any way to get a Flow ID by it’s name, project, & version as there is with the CLI?
    Michael
    Bouke Krom
    2 replies
    Copy to Clipboard
  • b

    Bastian Röhrig

    1 year ago
    Hey everyone, I am using the
    create_flow_run
    and
    get_task_run_result
    to interact with child flows. Now I would love to set some general task properties like
    state_handlers
    and
    task_run_name
    on these. Maybe I am missing something, but I can't figure out how to do this without writing my own wrapper task. Is there a way to do this?
    b
    Kevin Kho
    4 replies
    Copy to Clipboard
  • Richard Pelgrim

    Richard Pelgrim

    1 year ago
    Hey folks! I'm struggling with implementing conditional logic inside my Prefect flow.This script works but this one with the conditional logic fails with a rather obscure repetitive error message. AFAICT I'm following the guidelines outline in the Prefect docs here. Would really appreciate any pointers on what might be going wrong here!
    File "/Users/rpelgrim/mambaforge/envs/prefect/lib/python3.9/multiprocessing/popen_spawn_posix.py", line 42, in _launch
        prep_data = spawn.get_preparation_data(process_obj._name)
      File "/Users/rpelgrim/mambaforge/envs/prefect/lib/python3.9/multiprocessing/spawn.py", line 154, in get_preparation_data
        _check_not_importing_main()
      File "/Users/rpelgrim/mambaforge/envs/prefect/lib/python3.9/multiprocessing/spawn.py", line 134, in _check_not_importing_main
        raise RuntimeError('''
    RuntimeError:
            An attempt has been made to start a new process before the
            current process has finished its bootstrapping phase.
    
            This probably means that you are not using fork to start your
            child processes and you have forgotten to use the proper idiom
            in the main module:
    
                if __name__ == '__main__':
                    freeze_support()
                    ...
    
            The "freeze_support()" line can be omitted if the program
            is not going to be frozen to produce an executable.
    Richard Pelgrim
    Kevin Kho
    17 replies
    Copy to Clipboard
  • Jeremy Phelps

    Jeremy Phelps

    1 year ago
    I'm having a strange error that just popped up one day after a completely unrelated code change:
    Unexpected error: ValueError('Cell is empty')
    Traceback (most recent call last):
      File "/usr/local/lib/python3.7/site-packages/distributed/protocol/pickle.py", line 49, in dumps
        result = pickle.dumps(x, **dump_kwargs)
    _pickle.PicklingError: Can't pickle <function create_job at 0x7fabe956fc20>: it's not the same object as tasks.common.create_job
    None of my Prefect tasks have been working since it first appeared. I tried this Stack Overflow answer but it didn't help: https://stackoverflow.com/a/1413299 What causes this error? The
    create_job
    function is always referred to by its full Python import path (
    tasks.common.create_job
    ) due to the Stack Overflow answer.
    Jeremy Phelps
    Kevin Kho
    18 replies
    Copy to Clipboard
  • Anh Nguyen

    Anh Nguyen

    1 year ago
    Hello everybody! When i use prefect to ETL data. I cant track mapping from fields data source to fields destination
    Anh Nguyen
    Kevin Kho
    3 replies
    Copy to Clipboard
  • chicago-joe

    chicago-joe

    1 year ago
    hey all, I'm trying to setup prefect on an ubuntu server instance. I've got it installed with sudo, python3.8, but I'm having trouble finding the config.toml file
    chicago-joe
    2 replies
    Copy to Clipboard