async_task on Nifi: unsupported environment ""

[bossie]

This processor will sometimes receive messages with an empty/unset "env" attribute: https://nifi-prod-01.vgt.vito.be:8443/nifi/?processGroupId=71b59592-0181-1000-ffff-ffffa690d1e2&componentIds=52d03513-4087-1149-0000-00007d731095

OpenEO async task on clustered Nifi: unsupported environment ""

Standard FlowFile Metadata:
        id = '8be57775-f584-4267-95c1-2793406ca22d'
        entryDate = 'Fri Sep 30 16:17:09 CEST 2022'
        fileSize = '202'
FlowFile Attributes:
        path = './'
        filename = '8be57775-f584-4267-95c1-2793406ca22d'
        task = '{"task_id": "poll_sentinelhub_batch_processes", "arguments": {"batch_job_id": "j-2b4704f1efb542a2970c05fd541cb581", "user_id": "[0aee24f6aaf35f49fde532665aea77b955b6f484caaa1404735111ae4cdf4f97@egi.eu](mailto:0aee24f6aaf35f49fde532665aea77b955b6f484caaa1404735111ae4cdf4f97@egi.eu)"}}'
        kafka.partition = '0'
        kafka.offset = '4650'
        task.1 = '{"task_id": "poll_sentinelhub_batch_processes", "arguments": {"batch_job_id": "j-2b4704f1efb542a2970c05fd541cb581", "user_id": "[0aee24f6aaf35f49fde532665aea77b955b6f484caaa1404735111ae4cdf4f97@egi.eu](mailto:0aee24f6aaf35f49fde532665aea77b955b6f484caaa1404735111ae4cdf4f97@egi.eu)"}}'
        kafka.timestamp = '1664547429181'
        kafka.topic = 'openeo-async-tasks'
        task.0 = '{"task_id": "poll_sentinelhub_batch_processes", "arguments": {"batch_job_id": "j-2b4704f1efb542a2970c05fd541cb581", "user_id": "[0aee24f6aaf35f49fde532665aea77b955b6f484caaa1404735111ae4cdf4f97@egi.eu](mailto:0aee24f6aaf35f49fde532665aea77b955b6f484caaa1404735111ae4cdf4f97@egi.eu)"}}'
        uuid = '8be57775-f584-4267-95c1-2793406ca22d'
        RouteOnAttribute.Route = 'unmatched'

This "env" attribute is set by the sender of the message and corresponds to the ASYNC_TASK_HANDLER_ENV envar (should be present in web app and batch job drivers).