prefect build -p

Beginning health checks...
System Version check: OK
Traceback (most recent call last):
  File "/opt/prefect/healthcheck.py", line 150, in <module>
    flows = import_flow_from_script_check(flow_file_paths)
  File "/opt/prefect/healthcheck.py", line 63, in import_flow_from_script_check
    flows.append(extract_flow_from_file(file_path=flow_file_path))
  File "/usr/local/lib/python3.8/site-packages/prefect/utilities/storage.py", line 86, in extract_flow_from_file
    exec(contents, exec_vals)
  File "<string>", line 129, in <module>
NameError: name '__file__' is not defined

foo.py

flowA

-p ./foo.py

-p foo.py

/pipelines/

flow.py, common_task.py

from .common_task import xxx

resiger

prefect.tasks.sql_server

from prefect.tasks.sql_server import SqlServerExecute

STORAGE = Docker(registry_url="<http://xxx.azurecr.io|xxx.azurecr.io>",
         image_name="prefect/test",
         dockerfile="Dockerfile",
         python_dependencies=["pyodbc"])

SQL = SqlServerExecute(db_name="myDb",
            user="user",
            host="<tcp:xxx.database.windows.net>",
            port=1433,
            driver="ODBC Driver 17 for SQL Server")

QUERY = """
  CREATE TABLE [dbo].[myTable] (
    [id] VARCHAR(22) COLLATE Latin1_General_100_BIN2 NOT NULL,
    [FirstName] VARCHAR(222) NULL,
    [LastName] VARCHAR(222) NULL
  )
"""

@task
def create_table():
  logger = prefect.context.get('logger')
  <http://logger.info|logger.info>("Create table in DW for loading the results")
  SQL.run(query=QUERY, password='myPass')

with Flow("candidates-flow", storage=STORAGE, run_config=RUN_CONFIG, executor=EXECUTOR) as flow:
  create_table()

An error occurred (ClientException) when calling the RegisterTaskDefinition operation: Too many concurrent attempts to create a new revision of the specified family.

idempotency_key

register

flow,storage.build

RunConfig/ECSRun

PREFECT__LOGGING__EXTRA_LOGGERS

flow.run_config = LocalRun(
    env={
        "PREFECT__LOGGING__EXTRA_LOGGERS": json.dumps([
            'foo.bar.aaa',
            'foo.bar.bbb',
        ])
    }
)

flow.run_config = LocalRun(
    env={
        "PREFECT__LOGGING__EXTRA_LOGGERS": json.dumps([
            'foo.bar.*'
        ])
    }
)

prefect.utilities.exceptions.AuthorizationError: [{'path': ['auth_info'], 'message': 'AuthenticationError: Forbidden', 'extensions': {'code': 'UNAUTHENTICATED'}}]

- name: PREFECT__CLOUD__AGENT__AUTH_TOKEN
  value: ''
- name: PREFECT__CLOUD__API
  value: <https://api.prefect.io>
- name: NAMESPACE
  value: default
- name: IMAGE_PULL_SECRETS
  value: ''
- name: PREFECT__CLOUD__AGENT__LABELS
  value: '[]'
- name: JOB_MEM_REQUEST
  value: ''
- name: JOB_MEM_LIMIT
  value: ''
- name: JOB_CPU_REQUEST
  value: ''
- name: JOB_CPU_LIMIT
  value: ''
- name: IMAGE_PULL_POLICY
  value: ''
- name: SERVICE_ACCOUNT_NAME
  value: ''
- name: PREFECT__BACKEND
  value: cloud
- name: PREFECT__CLOUD__AGENT__AGENT_ADDRESS
  value: http://:8080
image: prefecthq/prefect:0.14

[2021-05-11 19:11:14+0200] ERROR - prefect.FlowRunner | Unexpected error: ModuleNotFoundError("No module named 'prefect'")

TypeError: execute() takes no keyword arguments

from prefect.tasks.sql_server import SqlServerExecute

SQL = SqlServerExecute(db_name="my"Db",
            user="user",
            host="<tcp:xxxs.database.windows.net>",
            port=1433,
            driver="ODBC Driver 17 for SQL Server")

QUERY = "CREATE TABLE [dbo].[CandidateDetails] ([CandidateId] VARCHAR(22) COLLATE Latin1_General_100_BIN2 NOT NULL,[FirstName] VARCHAR(222) NULL,[LastName] VARCHAR(222) NULL)"

@task
def create_table():
  logger = prefect.context.get('logger')
  <http://logger.info|logger.info>("Create table in DW for loading the results")
  SQL.run(query=QUERY, password='myPass')

prefect --help

from prefect import Task, Flow, task

@task()
def task_success():
    print("Success!")
    return {'p': 1, 'k': 2, 'j': 3}


@task()
def task_to_fail(p, k):
    print(f"p: {p}; k: {k}")
    raise NotImplementedError()


with Flow("catch-all-failed-flow", state_handlers=[STATE_HANDLER_CATCH_ALL_FAILED]) as flow:
    ts = task_success()
    tf = task_to_fail(ts) # how can I map p and k params to the task_to_fail task instead of passing the whole dict in p but nothing as k

flow.run()

from prefect.configuration import config

config.tasks.defaults.max_retries = 2
config.tasks.defaults.retry_delay = datetime.timedelta(seconds=10)

[~] -> docker run -it prefecthq/<server:core-0.14.18> pip show prefect
Name: prefect
Version: 0.14.16+95.g377f2fe7a

click >= 7.0.0

click v8.0.0

click v7.1.2

core-0.14.18

AttributeError: ‘Context’ object has no attribute ‘flow_run_id’

prefect.context.flow_run_id

nvidia-docker