Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-06-04 Thread via GitHub
alizademhdi closed pull request #38628: Fix inital value for _batch_id attribute in livy operator URL: https://github.com/apache/airflow/pull/38628 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-05-25 Thread via GitHub
github-actions[bot] commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2131753717 This pull request has been automatically marked as stale because it has not had recent activity. It will be closed in 5 days if no further activity occurs. Thank you for you

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-04-10 Thread via GitHub
mateuslatrova commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2048507160 Thanks for the idea, @potiuk! That makes much more sense. I will try to implement it. -- This is an automated message from the Apache Git Service. To respond to the message, ple

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-04-04 Thread via GitHub
potiuk commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2036432683 Trigger should (even if it times out) produce a trigger event with batch_id information in it. So Airflow should not kill trigger, it should timeout itself before Airflow does it and sig

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-04-03 Thread via GitHub
mateuslatrova commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2035812370 Hi! I was also working on issue #37898 , and one of the requirements the author mentioned was: > "The Livy operator should fail due to a timeout, and simultaneously, it sh

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-04-01 Thread via GitHub
alizademhdi commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2030790977 Sure. I will try. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-03-31 Thread via GitHub
eladkal commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2028687443 Can you add unit test to avoid regression? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

Re: [PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-03-30 Thread via GitHub
alizademhdi commented on PR #38628: URL: https://github.com/apache/airflow/pull/38628#issuecomment-2028073596 Fixed static tests :D -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[PR] Fix inital value for _batch_id attribute in livy operator [airflow]

2024-03-29 Thread via GitHub
alizademhdi opened a new pull request, #38628: URL: https://github.com/apache/airflow/pull/38628 ### Related issue #37898 ### Explain when the livy operator is rewaked up after trigger is time out, the _batch_id is not initialized, which cause it to raise this exeption: `