import prefect
c = prefect.Client()

prefect server start

Deploying flow run ...

kubectl get all

READY 0/1

kubectl logs deployment/prefect-agent

prefect.utilities.exceptions.ClientError: Malformed response received from API.

postgres, towel, hasura, graphql, apollo, ui

E0611: No name 'task' in module 'prefect' (no-name-in-module)

executor = DaskExecutor(address=cluster.scheduler_address)
……………………….
flow_state = flow.run(executor=executor)

flow.register(project_name="test")
flow.run_agent()
flow_state = flow.run(executor=executor)

flow.environment.executor = executor
flow.register(project_name="test")
flow.run_agent()

Unexpected error: ConnectionError(MaxRetryError('None: Max retries exceeded with url: /graphql (Caused by None)'))

flow.environment = RemoteDaskEnvironment(cluster.scheduler_address)
flow.register(project_name="test")
flow.run_agent()

prefect agent local start --api <http://Apollo_server_IP:4200>

prefect.utilities.exceptions.ClientError: 400 Client Error: Bad Request for url: <http://10.0.4.45:4200/graphql>

This is likely caused by a poorly formatted GraphQL query or mutation. GraphQL sent:

query {
    mutation($input: create_flow_from_compressed_string_input!) {
            create_flow_from_compressed_string(input: $input) {
                id
        }
    }
}

env_vars

prefect server create-tenant --name default --slug default

default

C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\environments\storage\docker.py:351: UserWarning: This Docker storage object has no `registry_url`, and will not be pushed.
  self._build_image(push=push)
[2020-11-11 11:09:22+0100] INFO - prefect.Docker | Building the flow's Docker storage...
Step 1/9 : FROM prefecthq/prefect:0.13.14-python3.7
 ---> 93545f019d66
Step 2/9 : RUN pip install pip --upgrade
 ---> Using cache
 ---> 04f7a3ff4972
Step 3/9 : RUN pip show prefect || pip install git+<https://github.com/PrefectHQ/prefect.git@0.13.14#egg=prefect[kubernetes]>
 ---> Using cache
 ---> 19e43c078e99
Step 4/9 : RUN pip install wheel
 ---> Using cache
 ---> e42095cd0936
Step 5/9 : RUN mkdir -p /opt/prefect/
 ---> Using cache
 ---> 926010edf84c
Step 6/9 : COPY hello-flow.flow /opt/prefect/flows/hello-flow.prefect
 ---> 70517ea739e4
Step 7/9 : COPY healthcheck.py /opt/prefect/healthcheck.py
 ---> ce25a709678c
Step 8/9 : ENV PREFECT__USER_CONFIG_PATH=/opt/prefect/config.toml
 ---> Running in 8e564fe71477
Removing intermediate container 8e564fe71477
 ---> cae7074f0b02
Step 9/9 : RUN python /opt/prefect/healthcheck.py '["/opt/prefect/flows/hello-flow.prefect"]' '(3, 7)'
 ---> Running in e0df9c491e35
Beginning health checks...
System Version check: OK
Cloudpickle serialization check: OK
Result check: OK
Environment dependency check: OK
All health checks passed.
Removing intermediate container e0df9c491e35
 ---> e73382d6b699
Successfully built e73382d6b699
Successfully tagged hello-flow:2020-11-11t10-09-20-404746-00-00
Traceback (most recent call last):
  File "C:\Program Files\JetBrains\PyCharm 2020.2\plugins\python\helpers\pydev\pydevd.py", line 1448, in _exec
    pydev_imports.execfile(file, globals, locals)  # execute the script
  File "C:\Program Files\JetBrains\PyCharm 2020.2\plugins\python\helpers\pydev\_pydev_imps\_pydev_execfile.py", line 18, in execfile
    exec(compile(contents+"\n", file, 'exec'), glob, loc)
  File "C:/Documentos/Coding/_trials/kubernetes/prefect/deployment_tutorial_flow.py", line 13, in <module>
    flow.register(project_name="myproject")
  File "C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\core\flow.py", line 1651, in register
    idempotency_key=idempotency_key,
  File "C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\client\client.py", line 788, in register
    retry_on_api_error=False,
  File "C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\client\client.py", line 281, in graphql
    retry_on_api_error=retry_on_api_error,
  File "C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\client\client.py", line 237, in post
    retry_on_api_error=retry_on_api_error,
  File "C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\client\client.py", line 413, in _request
    session=session, method=method, url=url, params=params, headers=headers
  File "C:\Documentos\Coding\_trials\kubernetes\venv\lib\site-packages\prefect\client\client.py", line 344, in _send_request
    raise ClientError(msg)
prefect.utilities.exceptions.ClientError: 400 Client Error: Bad Request for url: <http://localhost:4200/graphql>
This is likely caused by a poorly formatted GraphQL query or mutation. GraphQL sent:
query {
    mutation($input: create_flow_from_compressed_string_input!) {
            create_flow_from_compressed_string(input: $input) {
                id
        }
    }
}
variables {
    {"input": {"project_id": "f89dd540-50d6-4abf-86f5-0119fa63bc73", "serialized_flow": "H4sIAFO4q18C/41TTW/bMAz9K4XPs2K3wYb1NmDracfehkHgZFoRIkuGPtIFgf/7SMW10yDFCvgg8VGPfI/0qXIwYPV4V+3QWl/31r9Un+6qdBxLdAzYo0pC+YCCQfE0Z0S1wy5bznLZWoqMEIgrYYgU+/WbWSDuy+VURZv1UkYyULe3CpUnc7nsVDLeiaf58EwYv/E5jTkxMT83Totv7siAcXP8NNENcvJSo8MACTuK9mAjEqCAepe9D2vv59Aej2sogV6ExL0ZpXcyjzEFhEFygMAUMhOmYLRGpjtVvXsj54xEAdbKmJXCGPtsudn9CwR9bnZaOjiANR0kf4sLnTYOxVViFA4PGGSOeIM1YApH2aGFC2UD/JUMGOTEhgWYAcnVNeXNVpRxMbmUVCnSJKRksBHtg2i31cQWYadx8Ys7DugUymUFSo47mODdgC4VfRb+oF1Q2h0gSVAgM4C+2svH++a+qduWvtQ2dfO1puu22X7Zfq4bujfV9H6PF6v20yuwPy5aKUZlJ5V3vdGrCe9TRTL+3N+pnLGTEGVUwYzpYtGKCHn7D4uoaAaL+HMq7Rxn/ldosVibyMPNwa4tM3uZ/mU1Ytz4MW3mRdqUpM2aIGagGDGfX6VfCR8h7T5i0KvX373a048xTf8AKiEd/mkEAAA=", "set_schedule_active": true, "version_group_id": null, "idempotency_key": null}}
}
python-BaseException

@task
def hello_task():
    logger = prefect.context.get("logger")
    <http://logger.info|logger.info>("Hello, Cloud!")

flow = Flow("hello-flow", tasks=[hello_task])
flow.storage = Docker()
flow.register(project_name="myproject")

Could not upgrade the database

graphql_1   | Could not upgrade the database!
graphql_1   | Error: Can't locate revision identified by '24f10aeee83e'

environment = KubernetesJobEnvironment(job_spec_file=f"{local_dir_path}/job_spec.yaml")
...
with Flow("k8s-example-flow", storage=storage, environment=environment) as flow:
    ...

flow.register(project_name="Test Project")

job_spec_file