@Marvin what is the best way to mock a prefect block value in prefect 2.x

Hi Everyone, Is there any workaround i can use Prefect with golang ?

@Marvin in prefect v2 how can i add a pip library in my case pandas to my deployments workers

@Marvin I'm trying to deploy a flow in python code with:

from prefect_demo_test import run_prefect_demo_flow
from prefect.runner.storage import LocalStorage
from pathlib import Path

if __name__ == '__main__':
    # Deploy a flow
    run_prefect_demo_flow.from_source(
        source=str(Path(__file__).parent),
        entrypoint="prefect_demo_test.py:run_prefect_demo_flow"
    ).deploy(
        name='deployed-demo-image-halcon-processing-workflow',
        work_pool_name='halcon-pool'
        # tags=['halcon','demo'],
        # parameters=dict({
        #     "storage_rootpath_variable_name":"prefect_storage_filepath",
        #     "project_variable_name":"current_project_name"}),
        # description='Demo workflow processing images with halcon from a deployment',  
    )

But i get an error response what is wrong? Error: prefect.deployments.runner.DeploymentApplyError: Error while applying deployment: Client error '422 Unprocessable Entity' for url 'http://127.0.0.1:4200/api/deployments/' Response: {'exception_message': 'Invalid request received.', 'exception_detail': [{'type': 'extra_forbidden', 'loc': ['body', 'concurrency_options'], 'msg': 'Extra inputs are not permitted', 'input': None}], 'request_body': {'name': 'deployed-demo-image-halcon-processing-workflow', 'flow_id': '6cd656ec-23ab-4310-82c4-0f3b90bbfd94', 'paused': False, 'schedules': [], 'concurrency_limit': None, 'concurrency_options': None, 'enforce_parameter_schema': True, 'parameter_openapi_schema': {'title': 'Parameters', 'type': 'object', 'properties': {'storage_rootpath_variable_name': {'position': 0, 'title': 'storage_rootpath_variable_name', 'type': 'string'}, 'project_variable_name': {'position': 1, 'title': 'project_variable_name', 'type': 'string'}}, 'required': ['storage_rootpath_variable_name', 'project_variable_name']}, 'parameters': {}, 'tags': [], 'pull_steps': [{'prefect.deployments.steps.set_working_directory': {'directory': 'C:\\repos\\ai-data-pipeline'}}], 'work_queue_name': None, 'work_pool_name': 'halcon-pool', 'storage_document_id': None, 'infrastructure_document_id': None, 'description': 'Runs the prefect ai data pipeline flow\n- Gets variables to laod a metadat file\n- Read metadata file and process images\n- Update metadata and write updates to storage', 'path': None, 'version': 'c9393244be33c404894a5c4581a89651', 'entrypoint': 'prefect_demo_test.py:run_prefect_demo_flow', 'job_variables': {}}}

@Marvin I have a deployed flow that I am trying to run. When I pass it the expected parameters, it is exiting with this error:

prefect.exceptions.SignatureMismatchError: Function expects parameters ['args', 'kwargs'] but was provided with parameters ['venue_id']

What might be going on here?

@Marvin I am trying out variables. Prefect cloud suggests I can format a variable in the way of json but when I use prefect cli to list out the variable, a pydantic error raises regarding expecting a string. I can upload the error shortly but am wondering if a job variable can be a dictionary.

@Marvin how do I specify Python package dependencies (i.e., ones from PyPI as well as locally available packages in a GitHub repository)

Hi everyone, I've been trying to daemonize workers on windows for automate runs and restarts. I use NSSM to create a service with path on a cmd file that run "cmd.exe /K "D:\QA\anaconda3\Scripts\activate.bat D:\QA\anaconda3 && conda activate D:\Database\envs & prefect worker start --pool "AG" --type process" But for some reason, the service doesn't poll the prefect cloud. Meanwhile, when I run this command line on a CMD then everything is fine. I fount this in the error log: sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) database is locked 2023-12-25 043835.968: [SQL: INSERT INTO worker (name, last_heartbeat_time, work_pool_id, id, created, updated) VALUES (:name, :last_heartbeat_time, :work_pool_id, :id, :created, :updated) ON CONFLICT (work_pool_id, name) DO UPDATE SET last_heartbeat_time = :param_1] .... 2023-12-25 043835.968: (Background on this error at: https://sqlalche.me/e/20/e3q8) Can anyone please help me on this??

Hoping somebody here is familiar with pdoc3 I am trying to generate documentation for a library with

pdoc3

. It works up until I hit a custom implementation of

prefect.serializers.Serializer

. The error involves the class's

__dispatch_key__

.

Hello, Trying to run multiple python scripts in prefect. My use case is that, each task should represent as an individual python script and these all scripts/ tasks can be combined to form a single flow . HOW IS THIS ACHIEVABLE? Can we run bash commands as a single task in prefect version 2. #C0106HZ1CMS #CL09KU1K7 #C0470L5UV2M