From d6cf03a4aa031ed8a0470542a58d9f570b3b215d Mon Sep 17 00:00:00 2001 From: Viren Baraiya Date: Thu, 19 Jan 2023 00:29:24 -0800 Subject: [PATCH] update orkes queues update orkes queue version. (#11) Update README.md Update README.md --- LICENSE | 460 ++++++++++-------- README.md | 18 +- .../conductor/dao/archive/ArchiveDAO.java | 4 +- .../dao/archive/ArchivedExecutionDAO.java | 4 +- .../dao/archive/ArchivedIndexDAO.java | 4 +- .../dao/archive/DocumentStoreDAO.java | 4 +- .../dao/archive/ScrollableSearchResult.java | 4 +- .../dao/indexer/IndexValueExtractor.java | 4 +- .../conductor/dao/indexer/IndexWorker.java | 4 +- .../dao/indexer/IndexWorkerProperties.java | 4 +- .../conductor/dao/indexer/TaskIndex.java | 4 +- .../conductor/dao/indexer/WorkflowIndex.java | 4 +- .../postgres/archive/PostgresArchiveDAO.java | 4 +- .../PostgresArchiveDAOConfiguration.java | 4 +- .../dao/postgres/archive/SearchQuery.java | 4 +- .../conductor/id/TimeBasedUUIDGenerator.java | 4 +- .../conductor/metrics/MetricsCollector.java | 4 +- .../conductor/dao/archive/TestScheduler.java | 4 +- .../dao/indexer/TestIndexValueExtractor.java | 4 +- .../dao/postgres/PostgresArchiveDAOTest.java | 4 +- .../PostgresArchivePerformanceTest.java | 4 +- .../dao/postgres/PostgresDAOTestUtil.java | 4 +- .../conductor/dao/postgres/UuidUtil.java | 4 +- build.gradle | 2 +- licenseheader.txt | 4 +- .../redis/config/AnyRedisCondition.java | 4 +- .../config/InMemoryRedisConfiguration.java | 4 +- .../config/RedisClusterConfiguration.java | 4 +- .../redis/config/RedisProperties.java | 4 +- .../config/RedisSentinelConfiguration.java | 4 +- .../config/RedisStandaloneConfiguration.java | 4 +- .../conductor/redis/dao/BaseDynoDAO.java | 4 +- .../conductor/redis/dao/OrkesMetadataDAO.java | 4 +- .../redis/dao/RedisEventHandlerDAO.java | 4 +- .../redis/dao/RedisExecutionDAO.java | 4 +- .../conductor/redis/dao/RedisMetadataDAO.java | 4 +- .../conductor/redis/dao/RedisPollDataDAO.java | 4 +- .../redis/dao/RedisRateLimitingDAO.java | 4 +- .../dynoqueue/ConfigurationHostSupplier.java | 4 +- .../dynoqueue/LocalhostHostSupplier.java | 4 +- .../conductor/redis/jedis/JedisCluster.java | 4 +- .../conductor/redis/jedis/JedisMock.java | 4 +- .../conductor/redis/jedis/JedisSentinel.java | 4 +- .../redis/jedis/JedisStandalone.java | 4 +- .../redis/jedis/OrkesJedisProxy.java | 4 +- .../com/netflix/dyno/connectionpool/Host.java | 4 +- .../dyno/connectionpool/HostBuilder.java | 4 +- .../dyno/connectionpool/HostSupplier.java | 4 +- .../config/TestObjectMapperConfiguration.java | 4 +- .../conductor/dao/ExecutionDAOTest.java | 4 +- .../conductor/dao/PollDataDAOTest.java | 4 +- .../conductor/redis/dao/BaseDynoDAOTest.java | 4 +- .../redis/dao/RedisEventHandlerDAOTest.java | 4 +- .../redis/dao/RedisExecutionDAOTest.java | 4 +- .../redis/dao/RedisMetadataDAOTest.java | 4 +- .../redis/dao/RedisPollDataDAOTest.java | 4 +- .../redis/dao/RedisRateLimitDAOTest.java | 4 +- .../jedis/ConfigurationHostSupplierTest.java | 4 +- .../redis/jedis/JedisClusterTest.java | 4 +- .../redis/jedis/JedisSentinelTest.java | 4 +- .../core/execution/OrkesWorkflowExecutor.java | 7 +- .../conductor/OrkesConductorApplication.java | 4 +- .../config/AWSCredentialsConfiguration.java | 4 +- .../config/SecurityDisabledConfig.java | 4 +- .../conductor/execution/tasks/HttpSync.java | 4 +- .../tasks/OrkesRestTemplateProvider.java | 64 ++- .../execution/tasks/SubWorkflowSync.java | 4 +- .../OrkesForkJoinDynamicTaskMapper.java | 4 +- .../orkes/conductor/rest/VersionResource.java | 4 +- .../conductor/rest/WorkflowResourceSync.java | 50 +- .../service/OrkesSweeperProperties.java | 4 +- .../server/service/OrkesWorkflowSweeper.java | 4 +- .../conductor/ui/UIContextGenerator.java | 4 +- 73 files changed, 477 insertions(+), 392 deletions(-) diff --git a/LICENSE b/LICENSE index 78ae7ea..2cc409e 100644 --- a/LICENSE +++ b/LICENSE @@ -1,201 +1,259 @@ -Apache License - Version 2.0, January 2004 - http://www.apache.org/licenses/ - - TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION - - 1. Definitions. - - "License" shall mean the terms and conditions for use, reproduction, - and distribution as defined by Sections 1 through 9 of this document. - - "Licensor" shall mean the copyright owner or entity authorized by - the copyright owner that is granting the License. - - "Legal Entity" shall mean the union of the acting entity and all - other entities that control, are controlled by, or are under common - control with that entity. For the purposes of this definition, - "control" means (i) the power, direct or indirect, to cause the - direction or management of such entity, whether by contract or - otherwise, or (ii) ownership of fifty percent (50%) or more of the - outstanding shares, or (iii) beneficial ownership of such entity. - - "You" (or "Your") shall mean an individual or Legal Entity - exercising permissions granted by this License. - - "Source" form shall mean the preferred form for making modifications, - including but not limited to software source code, documentation - source, and configuration files. - - "Object" form shall mean any form resulting from mechanical - transformation or translation of a Source form, including but - not limited to compiled object code, generated documentation, - and conversions to other media types. - - "Work" shall mean the work of authorship, whether in Source or - Object form, made available under the License, as indicated by a - copyright notice that is included in or attached to the work - (an example is provided in the Appendix below). - - "Derivative Works" shall mean any work, whether in Source or Object - form, that is based on (or derived from) the Work and for which the - editorial revisions, annotations, elaborations, or other modifications - represent, as a whole, an original work of authorship. For the purposes - of this License, Derivative Works shall not include works that remain - separable from, or merely link (or bind by name) to the interfaces of, - the Work and Derivative Works thereof. - - "Contribution" shall mean any work of authorship, including - the original version of the Work and any modifications or additions - to that Work or Derivative Works thereof, that is intentionally - submitted to Licensor for inclusion in the Work by the copyright owner - or by an individual or Legal Entity authorized to submit on behalf of - the copyright owner. For the purposes of this definition, "submitted" - means any form of electronic, verbal, or written communication sent - to the Licensor or its representatives, including but not limited to - communication on electronic mailing lists, source code control systems, - and issue tracking systems that are managed by, or on behalf of, the - Licensor for the purpose of discussing and improving the Work, but - excluding communication that is conspicuously marked or otherwise - designated in writing by the copyright owner as "Not a Contribution." - - "Contributor" shall mean Licensor and any individual or Legal Entity - on behalf of whom a Contribution has been received by Licensor and - subsequently incorporated within the Work. - - 2. Grant of Copyright License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - copyright license to reproduce, prepare Derivative Works of, - publicly display, publicly perform, sublicense, and distribute the - Work and such Derivative Works in Source or Object form. - - 3. Grant of Patent License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - (except as stated in this section) patent license to make, have made, - use, offer to sell, sell, import, and otherwise transfer the Work, - where such license applies only to those patent claims licensable - by such Contributor that are necessarily infringed by their - Contribution(s) alone or by combination of their Contribution(s) - with the Work to which such Contribution(s) was submitted. If You - institute patent litigation against any entity (including a - cross-claim or counterclaim in a lawsuit) alleging that the Work - or a Contribution incorporated within the Work constitutes direct - or contributory patent infringement, then any patent licenses - granted to You under this License for that Work shall terminate - as of the date such litigation is filed. - - 4. Redistribution. You may reproduce and distribute copies of the - Work or Derivative Works thereof in any medium, with or without - modifications, and in Source or Object form, provided that You - meet the following conditions: - - (a) You must give any other recipients of the Work or - Derivative Works a copy of this License; and - - (b) You must cause any modified files to carry prominent notices - stating that You changed the files; and - - (c) You must retain, in the Source form of any Derivative Works - that You distribute, all copyright, patent, trademark, and - attribution notices from the Source form of the Work, - excluding those notices that do not pertain to any part of - the Derivative Works; and - - (d) If the Work includes a "NOTICE" text file as part of its - distribution, then any Derivative Works that You distribute must - include a readable copy of the attribution notices contained - within such NOTICE file, excluding those notices that do not - pertain to any part of the Derivative Works, in at least one - of the following places: within a NOTICE text file distributed - as part of the Derivative Works; within the Source form or - documentation, if provided along with the Derivative Works; or, - within a display generated by the Derivative Works, if and - wherever such third-party notices normally appear. The contents - of the NOTICE file are for informational purposes only and - do not modify the License. You may add Your own attribution - notices within Derivative Works that You distribute, alongside - or as an addendum to the NOTICE text from the Work, provided - that such additional attribution notices cannot be construed - as modifying the License. - - You may add Your own copyright statement to Your modifications and - may provide additional or different license terms and conditions - for use, reproduction, or distribution of Your modifications, or - for any such Derivative Works as a whole, provided Your use, - reproduction, and distribution of the Work otherwise complies with - the conditions stated in this License. - - 5. Submission of Contributions. Unless You explicitly state otherwise, - any Contribution intentionally submitted for inclusion in the Work - by You to the Licensor shall be under the terms and conditions of - this License, without any additional terms or conditions. - Notwithstanding the above, nothing herein shall supersede or modify - the terms of any separate license agreement you may have executed - with Licensor regarding such Contributions. - - 6. Trademarks. This License does not grant permission to use the trade - names, trademarks, service marks, or product names of the Licensor, - except as required for reasonable and customary use in describing the - origin of the Work and reproducing the content of the NOTICE file. - - 7. Disclaimer of Warranty. Unless required by applicable law or - agreed to in writing, Licensor provides the Work (and each - Contributor provides its Contributions) on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - implied, including, without limitation, any warranties or conditions - of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A - PARTICULAR PURPOSE. You are solely responsible for determining the - appropriateness of using or redistributing the Work and assume any - risks associated with Your exercise of permissions under this License. - - 8. Limitation of Liability. In no event and under no legal theory, - whether in tort (including negligence), contract, or otherwise, - unless required by applicable law (such as deliberate and grossly - negligent acts) or agreed to in writing, shall any Contributor be - liable to You for damages, including any direct, indirect, special, - incidental, or consequential damages of any character arising as a - result of this License or out of the use or inability to use the - Work (including but not limited to damages for loss of goodwill, - work stoppage, computer failure or malfunction, or any and all - other commercial damages or losses), even if such Contributor - has been advised of the possibility of such damages. - - 9. Accepting Warranty or Additional Liability. While redistributing - the Work or Derivative Works thereof, You may choose to offer, - and charge a fee for, acceptance of support, warranty, indemnity, - or other liability obligations and/or rights consistent with this - License. However, in accepting such obligations, You may act only - on Your own behalf and on Your sole responsibility, not on behalf - of any other Contributor, and only if You agree to indemnify, - defend, and hold each Contributor harmless for any liability - incurred by, or claims asserted against, such Contributor by reason - of your accepting any such warranty or additional liability. - - END OF TERMS AND CONDITIONS - - APPENDIX: How to apply the Apache License to your work. - - To apply the Apache License to your work, attach the following - boilerplate notice, with the fields enclosed by brackets "{}" - replaced with your own identifying information. (Don't include - the brackets!) The text should be enclosed in the appropriate - comment syntax for the file format. We also recommend that a - file or class name and description of purpose be included on the - same "printed page" as the copyright notice for easier - identification within third-party archives. - - Copyright {yyyy} Orkes, Inc. - - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. \ No newline at end of file +Orkes Community License Agreement + + PLEASE READ THIS ORKES COMMUNITY LICENSE AGREEMENT (“Agreement”). BY + DOWNLOADING, INSTALLING, USING OR DISTRIBUTING THE SOFTWARE + (DEFINED BELOW) (“Software”), YOU AND ANY ENTITY YOU REPRESENT (“Licensee” + or “you”) AGREE TO BE BOUND BY THIS AGREEMENT WITH ORKES, INC., A + DELAWARE CORPORATION (“Orkes”). IF AT ANYTIME YOU DO NOT AGREE TO ALL + OF THE TERMS OF THIS AGREEMENT, THEN DO NOT DOWNLOAD, INSTALL, USE + OR DISTRIBUTE THE SOFTWARE AND IMMEDIATELY CEASE ALL USE OF THE + SOFTWARE. + + By agreeing to this Agreement, you represent that you have full power, capacity and authority to + accept the terms of this Agreement. If you are accepting the terms of this Agreement on behalf + of an employer or another entity, you and such employer or other entity represent that you have + full legal authority to bind such employer or other entity to this Agreement. + + Orkes and Licensee agree to the following terms and conditions: + + Article 1 + Definitions + + 1.1 “Conductor Community Software” means the Conductor community + software, sometimes referred to by the community as Netflix Conductor, + contributed by the community under an Apache 2.0 license, which has been made + available at https://github.com/Netflix/conductor. + + 1.2 “Intellectual Property Rights” mean all legally protectable proprietary or + intellectual property rights in the United States, and anywhere in the world, past, + present and future, including without limitation any patent, copyright, or trade + secret. For the purposes of this Agreement, Intellectual Property Rights do not + include trademarks. + + 1.3 “Source Code” means software in source code or human readable form. + + 1.4 “Source Materials” means those portions of the Software furnished to + Licensee by Orkes in Source Code. + + 1.5 “Software” means the Orkes software licensed under this Agreement as may + be identified at the following url: https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt + + Article 2 + License Grant + + 2.1 Software License. As of the Effective Date, subject to the terms and + conditions of this Agreement, including, without limitation, Article 3 (License + Restrictions and Intellectual Property Rights), Orkes grants Licensee a limited, + non-exclusive, non-transferable, and non-sublicensable license, to: + + (a) evaluate the Software in Licensee’s development and testing environments; + (b) use the Software internally for Licensee’s internal business purposes; + (c) modify and make derivative works of the Software; + (d) reproduce the Software; and + (e) distribute Software in binary or Source Code form. + + 2.2 Conditions to License. The licenses under Article 2 (License Grants) are + conditioned upon Licensee’s compliance with the terms of this Agreement + including without limitation Article 3 (License Restrictions and Intellectual + Property Rights). + + 2.3 Third Party Intellectual Property. The Software may use, include or rely on + third-party software or other Intellectual Property Rights (“Third-Party Intellectual + Property”). Other than the Conductor Community Software included in the + Software that is licensed under the Apache 2.0 license, any Third Party Intellectual + Property that Orkes provides to Licensee is for convenience only, and is not part of + the Software and is not licensed hereunder. Licensee is solely responsible for + procuring and complying with, and shall procure and comply with, any necessary + license rights if Licensee uses any Third-Party Intellectual Property. + + Article 3 + License Restrictions and Intellectual Property Rights + + 3.1 Orkes Software Notice. Licensee shall not remove or modify any Orkes or + third-party copyright or other proprietary notices on the Software. Additionally, + Licensee shall provide the following notice on each copy of Software: + + THIS SOFTWARE IS MADE AVAILABLE BY ORKES, INC., A DELAWARE + CORPORATION (“Orkes”) UNDER THE ORKES COMMUNITY LICENSE + AGREEMENT (“Agreement”). BY DOWNLOADING, INSTALLING, USING + OR DISTRIBUTING THE SOFTWARE, YOU AND ANY ENTITY YOU + REPRESENT (“Licensee” or “you”) AGREE TO BE BOUND BY THE ORKES + COMMUNITY LICENSE AGREEMENT AT ALL TIMES. IF YOU DO NOT + AGREE TO ALL OF THE TERMS OF THE ORKES COMMUNITY LICENSE + AGREEMENT AT ANY TIME, THEN DO NOT DOWNLOAD, INSTALL, + USE OR DISTRIBUTE THE SOFTWARE AND YOU SHALL IMMEDIATELY + CEASE ANY USE OF THE SOFTWARE. + + 3.2 Restrictions. Licensee agrees that Licensee shall not: (i) use the Software + outside of the scope of the license granted hereunder or in violation of any + restrictions hereunder; or (ii) export or re-export the Software directly or indirectly + in violation of the laws of the United States or any other jurisdiction. + + 3.3 Competitive Products. Licensee shall not (i) use or provide the Software as + a service for any third party (including as software-as-a-service, time-sharing or + service bureau), (ii) otherwise provide the Software to a third party in competition + with the Software or in competition with Orkes, (iii) use the Software (including + any Source Materials) to develop any product, technology or service that competes + with the Software or any Orkes product or service or (iv) allow its personnel who + have access to the Software to develop any such competitive product, technology or + service. + + 3.4 Open Source Software. Licensee shall not use or combine the Source + Materials (or the Software) with open-source software or other items in any manner + which would subject the Software to any additional open source software terms and + conditions. For clarity, the foregoing does not prohibit Licensee from combining + and using the Software with Conductor code that is subject only to the Apache 2.0 + license or subject to an Orkes community license. + + 3.5 Ownership by Orkes. Orkes retains all Orkes’ Intellectual Property Rights + covering or embodied in the Software, subject to the limited licenses granted to + Licensee under this Agreement and any third-party rights in the Software. + + 3.6 No Trademark License. Licensee acquires no right or license to any + trademarks of Orkes hereunder. + + 3.7 No Other Rights. All Intellectual Property Rights of Orkes not expressly + granted to Licensee in this Agreement are expressly reserved by Orkes. Without + limitation, Licensee receives no right or license, by implication, estoppel or + otherwise, to any software, product, technology or Intellectual Property Rights not + embodied in the Software, even if such other software, technology or Intellectual + Property Rights are useful or necessary in connection with the Software. Licensee + agrees not to claim, assert or assist in the claim or assertion of any such license or + right disclaimed as provided above. + + Article 4 + No Warranty + + THE SOFTWARE IS PROVIDED “AS-IS” WITHOUT ANY WARRANTY OF ANY KIND. + TO THE MAXIMUM EXTENT PERMITTED BY LAW, ORKES DISCLAIMS ALL + WARRANTIES, CONDITIONS AND REPRESENTATIONS (EXPRESS OR IMPLIED, ORAL + OR WRITTEN) WITH RESPECT TO THE SOFTWARE, INCLUDING, WITHOUT + LIMITATION, WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A + PARTICULAR PURPOSE. + + Article 5 + Licensee Responsibility + + Licensee, and not Orkes, is solely responsible for any warranties and covenants Licensee makes in + connection with the Licensee’s products and services as well as the Software and any results thereof, and + any resulting claims from any customers or other third party. Without limiting the foregoing, Licensee is + responsible for complying with applicable law in connection with use of the Software and verifying and + validating the suitability and reliability of the Software for all of Licensee’s use thereof. Further, Licensee + must take prudent steps to protect against failures when the Software or results thereof is incorporated in a + system or application, including providing back-up and shut-down mechanisms. + + Article 6 + Limitation of Liability + + 6.1 Limitation of Liability. ORKES SHALL NOT BE LIABLE TO LICENSEE + FOR ANY SPECIAL, INDIRECT, INCIDENTAL, EXEMPLARY OR + CONSEQUENTIAL DAMAGES, INCLUDING, WITHOUT LIMITATION, LOST + PROFITS, BUSINESS INTERRUPTION OR LOSS OF INFORMATION, IN ANY + WAY RELATED TO THIS AGREEMENT, REGARDLESS OF WHETHER + SUCH PARTY WAS ADVISED OF THE POSSIBILITY OF ANY OF THE + FOREGOING. IN NO EVENT SHALL THE TOTAL COLLECTIVE LIABILITY + OF ORKES FOR ALL CLAIMS HEREUNDER OR IN ANY WAY RELATED TO + THIS AGREEMENT EXCEED THE GREATER OF (I) THE TWENTY + PERCENT (20%) OF AGGREGATE AMOUNTS PAID OR OWED BY + LICENSEE UNDER THIS AGREEMENT IN THE PRECEDING TWELVE (12) + MONTHS OR (II) ONE HUNDRED DOLLARS ($100). + + 6.2 Allocation of Risk. The warranty disclaimer and limitations of liability set + forth in this Agreement shall apply irrespective of any failure of the essential + purpose of any limited remedy. Licensee acknowledges and agrees that, but for + these provisions, Orkes would not have made the Software available to Licensee + under the terms contemplated under this Agreement. + + 6.3 Applicable Law. The warranty disclaimer and limitations of liability set + forth in this Agreement shall not apply to the extent prohibited by law, in which + case the disclaimer or limitation shall be modified to disclaim and/or limit in + accordance with applicable law. Without limiting the foregoing, to the extent + required by law, the foregoing limitations shall not apply to claims due to fraud, + bodily injury or death. + + Article 7 + Termination + + 7.1 Term. This Agreement shall become effective until terminated. + + 7.2 Termination. This Agreement shall terminate automatically if Licensee + materially breaches of this Agreement or any term of this Agreement or if Licensee + (a) becomes insolvent or bankrupt, (b) dissolves or ceases to conduct business in the + ordinary course, (c) makes an assignment for the benefit of its creditors, (d) + commences any insolvency, receivership, bankruptcy or other similar proceeding + for the settlement of its debts or (e) has commenced against it any insolvency, + receivership, bankruptcy or other similar proceeding for the settlement of its debts + that is not dismissed within thirty (30) days after notice of such proceeding. + + 7.3 Effect of Termination. If this Agreement is terminated or expires for any + reason, all rights granted hereunder to Licensee shall terminate, and Licensee shall + immediately cease all use of the Software. The provisions of Article 1 + (Definitions), Article 3 (License Restrictions and Intellectual Property Rights), + Article 4 (No Warranty), Article 5 (Limitation of Liability), Article 6 (Term and + Termination) and Article 7 (Miscellaneous) shall survive termination of this + Agreement. + + Article 8 + Miscellaneous + + 8.1 Relationship of Parties. The Parties to this Agreement are independent + contractors, and this Agreement shall not establish any relationship of partnership, + joint venture, employment, franchise or agency between the Parties. Neither Party + shall have the power to bind the other or incur obligations on the other’s behalf + without the other Party’s prior written consent. + + 8.2 Assignment. Licensee shall not have the right to assign this Agreement, in + whole or in part, without Orkes’s prior written consent; assignment by operation of + law or change of control Licensee is prohibited. Orkes may assign this Agreement + without consent. Any attempt to assign this Agreement, other than as permitted + above, shall be null and void. + + 8.3 Federal Acquisition. This provision applies to all acquisitions of the + Software by or for the Federal Government, whether by any prime contractor or + subcontractor and whether under any procurement contract, grant, cooperative + agreement or other activity by or with the Federal Government. By accepting + delivery of the Software, the Government agrees the Software qualifies as + “commercial” computer software within the meaning of the acquisition regulations + applicable to this procurement. The terms and conditions of this Agreement shall + pertain to the Government’s use and disclosure of the software and shall supersede + any conflicting contractual terms or conditions. If this Agreement fails to meet the + Government’s needs or is inconsistent in any respect with Federal law, the + Government agrees to return the Software, unused, to Orkes. + + 8.4 Governing Law. This Agreement shall be governed by, and construed in + accordance with, the laws of the State of California, U.S.A., applicable to contracts + made in full and performed in the State of California, U.S.A., without reference to + any conflict of law or choice of law principles that would cause the application of + laws of any other jurisdiction. The United Nations Convention on Contracts for the + International Sales of Goods shall not apply to this Agreement. + + 8.5 Jurisdiction and Venue. Jurisdiction and venue for any dispute arising from + or related to this Agreement shall be in the state and federal courts of Santa Clara + County, California, USA, and each party hereby consents to the jurisdiction and + venue of such courts. + + 8.6 Language of Agreement. This Agreement is made in the English language + only, and the English language version shall control in all respects. In the event that + this Agreement is translated into another language, such translation shall not be + binding upon the Parties. + + 8.7 Severability. If any provision of this Agreement, or the application thereof, + shall for any reason and to any extent be determined by a court of competent + jurisdiction to be invalid or unenforceable under applicable law, a valid provision + that most closely matches the intent of the original shall be substituted, and the + remaining provisions of this Agreement shall be interpreted so as best to reasonably + effect its original intent. + + 8.8 Waiver. The failure by either Party to enforce any provision of this + Agreement shall not constitute a waiver of future enforcement of that or any other + provision. + + 8.9 Entire Agreement. This Agreement contains the complete understanding + and agreement of the parties and supersedes all prior or contemporaneous + agreements or understandings, oral or written, relating to the subject matter herein. + Any waiver, modification or amendment of any provision of this Agreement shall + be effective only if in writing and signed by duly authorized representatives of the + Parties. No inconsistent or additional terms or conditions in any document provided + by Licensee, including any purchase orders, purchase agreements, requests for + proposals, bills of lading or the like shall apply to this Agreement or the activities + hereunder, and any such terms or conditions are hereby rejected. \ No newline at end of file diff --git a/README.md b/README.md index 084ef95..1a66ba7 100644 --- a/README.md +++ b/README.md @@ -88,16 +88,10 @@ Use GitHub issue tracking for filing issues and Discussion Forum for any other q [Orkes](http://orkes.io) development team creates and maintains the Orkes-Conductor releases. ## License -Copyright 2022 Orkes, Inc. +Copyright 2022 Orkes, Inc -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. +Licensed under Orkes Community License. You may obtain a copy of the License at: +``` +https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt +``` +Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. \ No newline at end of file diff --git a/archive/src/main/java/io/orkes/conductor/dao/archive/ArchiveDAO.java b/archive/src/main/java/io/orkes/conductor/dao/archive/ArchiveDAO.java index ce175e4..58bc968 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/archive/ArchiveDAO.java +++ b/archive/src/main/java/io/orkes/conductor/dao/archive/ArchiveDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedExecutionDAO.java b/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedExecutionDAO.java index 3d36d1a..d73409e 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedExecutionDAO.java +++ b/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedExecutionDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedIndexDAO.java b/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedIndexDAO.java index e85c878..6a2ac24 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedIndexDAO.java +++ b/archive/src/main/java/io/orkes/conductor/dao/archive/ArchivedIndexDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/archive/DocumentStoreDAO.java b/archive/src/main/java/io/orkes/conductor/dao/archive/DocumentStoreDAO.java index fa7c9e4..4c45f17 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/archive/DocumentStoreDAO.java +++ b/archive/src/main/java/io/orkes/conductor/dao/archive/DocumentStoreDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/archive/ScrollableSearchResult.java b/archive/src/main/java/io/orkes/conductor/dao/archive/ScrollableSearchResult.java index 7cfc62b..c0dfe6b 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/archive/ScrollableSearchResult.java +++ b/archive/src/main/java/io/orkes/conductor/dao/archive/ScrollableSearchResult.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexValueExtractor.java b/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexValueExtractor.java index 0100c8c..e2518bc 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexValueExtractor.java +++ b/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexValueExtractor.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorker.java b/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorker.java index bf6ed15..cb13d01 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorker.java +++ b/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorker.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorkerProperties.java b/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorkerProperties.java index ab34648..7811821 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorkerProperties.java +++ b/archive/src/main/java/io/orkes/conductor/dao/indexer/IndexWorkerProperties.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/indexer/TaskIndex.java b/archive/src/main/java/io/orkes/conductor/dao/indexer/TaskIndex.java index 6e00773..4395a14 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/indexer/TaskIndex.java +++ b/archive/src/main/java/io/orkes/conductor/dao/indexer/TaskIndex.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/indexer/WorkflowIndex.java b/archive/src/main/java/io/orkes/conductor/dao/indexer/WorkflowIndex.java index eb6e847..32efcfb 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/indexer/WorkflowIndex.java +++ b/archive/src/main/java/io/orkes/conductor/dao/indexer/WorkflowIndex.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAO.java b/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAO.java index 50f5a30..1c4624e 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAO.java +++ b/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAOConfiguration.java b/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAOConfiguration.java index 27d2cd8..cc84c1f 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAOConfiguration.java +++ b/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/PostgresArchiveDAOConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/SearchQuery.java b/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/SearchQuery.java index 804b632..aafef30 100644 --- a/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/SearchQuery.java +++ b/archive/src/main/java/io/orkes/conductor/dao/postgres/archive/SearchQuery.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/id/TimeBasedUUIDGenerator.java b/archive/src/main/java/io/orkes/conductor/id/TimeBasedUUIDGenerator.java index 934fa95..eb27b38 100644 --- a/archive/src/main/java/io/orkes/conductor/id/TimeBasedUUIDGenerator.java +++ b/archive/src/main/java/io/orkes/conductor/id/TimeBasedUUIDGenerator.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/main/java/io/orkes/conductor/metrics/MetricsCollector.java b/archive/src/main/java/io/orkes/conductor/metrics/MetricsCollector.java index 322f3f8..cd00980 100644 --- a/archive/src/main/java/io/orkes/conductor/metrics/MetricsCollector.java +++ b/archive/src/main/java/io/orkes/conductor/metrics/MetricsCollector.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/test/java/io/orkes/conductor/dao/archive/TestScheduler.java b/archive/src/test/java/io/orkes/conductor/dao/archive/TestScheduler.java index a949ef2..eabb005 100644 --- a/archive/src/test/java/io/orkes/conductor/dao/archive/TestScheduler.java +++ b/archive/src/test/java/io/orkes/conductor/dao/archive/TestScheduler.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/test/java/io/orkes/conductor/dao/indexer/TestIndexValueExtractor.java b/archive/src/test/java/io/orkes/conductor/dao/indexer/TestIndexValueExtractor.java index 2f5e240..ced1698 100644 --- a/archive/src/test/java/io/orkes/conductor/dao/indexer/TestIndexValueExtractor.java +++ b/archive/src/test/java/io/orkes/conductor/dao/indexer/TestIndexValueExtractor.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchiveDAOTest.java b/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchiveDAOTest.java index 17fe5f8..93f4b00 100644 --- a/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchiveDAOTest.java +++ b/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchiveDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchivePerformanceTest.java b/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchivePerformanceTest.java index f952bab..8f89abc 100644 --- a/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchivePerformanceTest.java +++ b/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresArchivePerformanceTest.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresDAOTestUtil.java b/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresDAOTestUtil.java index 203cf7f..6fa204d 100644 --- a/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresDAOTestUtil.java +++ b/archive/src/test/java/io/orkes/conductor/dao/postgres/PostgresDAOTestUtil.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/archive/src/test/java/io/orkes/conductor/dao/postgres/UuidUtil.java b/archive/src/test/java/io/orkes/conductor/dao/postgres/UuidUtil.java index f24d186..ed18fd9 100644 --- a/archive/src/test/java/io/orkes/conductor/dao/postgres/UuidUtil.java +++ b/archive/src/test/java/io/orkes/conductor/dao/postgres/UuidUtil.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/build.gradle b/build.gradle index b162085..1858fda 100644 --- a/build.gradle +++ b/build.gradle @@ -29,7 +29,7 @@ ext { revAwsSdk : '1.12.153', revProtoBuf : '3.13.0', revRarefiedRedis : '0.0.17', - revOrkesQueues : '1.0.1' + revOrkesQueues : '1.0.3' ] } diff --git a/licenseheader.txt b/licenseheader.txt index 8145074..60e5820 100644 --- a/licenseheader.txt +++ b/licenseheader.txt @@ -1,10 +1,10 @@ /* * Copyright $YEAR Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/config/AnyRedisCondition.java b/persistence/src/main/java/com/netflix/conductor/redis/config/AnyRedisCondition.java index e6d7f52..0789d72 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/config/AnyRedisCondition.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/config/AnyRedisCondition.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/config/InMemoryRedisConfiguration.java b/persistence/src/main/java/com/netflix/conductor/redis/config/InMemoryRedisConfiguration.java index ae3ac2b..8913bc2 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/config/InMemoryRedisConfiguration.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/config/InMemoryRedisConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisClusterConfiguration.java b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisClusterConfiguration.java index 38a379b..1f5105b 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisClusterConfiguration.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisClusterConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisProperties.java b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisProperties.java index e8f7b52..2aa6776 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisProperties.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisProperties.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisSentinelConfiguration.java b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisSentinelConfiguration.java index 92bb732..029ede8 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisSentinelConfiguration.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisSentinelConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisStandaloneConfiguration.java b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisStandaloneConfiguration.java index e6c1955..5f61fdd 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/config/RedisStandaloneConfiguration.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/config/RedisStandaloneConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/BaseDynoDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/BaseDynoDAO.java index b471347..8655520 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/BaseDynoDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/BaseDynoDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/OrkesMetadataDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/OrkesMetadataDAO.java index 17c154d..13fc6aa 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/OrkesMetadataDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/OrkesMetadataDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAO.java index 49c6cb5..724d6d9 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java index 59ebd07..b70001e 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisMetadataDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisMetadataDAO.java index ec4b96f..c5f5572 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisMetadataDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisMetadataDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisPollDataDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisPollDataDAO.java index b4474ba..aeb27ac 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisPollDataDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisPollDataDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisRateLimitingDAO.java b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisRateLimitingDAO.java index 549584d..9a5cc49 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisRateLimitingDAO.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dao/RedisRateLimitingDAO.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/ConfigurationHostSupplier.java b/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/ConfigurationHostSupplier.java index a1782fd..296212a 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/ConfigurationHostSupplier.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/ConfigurationHostSupplier.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/LocalhostHostSupplier.java b/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/LocalhostHostSupplier.java index 3f74f3c..7834271 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/LocalhostHostSupplier.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/dynoqueue/LocalhostHostSupplier.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisCluster.java b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisCluster.java index 6b0a938..fc989bf 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisCluster.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisCluster.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisMock.java b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisMock.java index ce4fba9..73f534c 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisMock.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisMock.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisSentinel.java b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisSentinel.java index c211889..7e305b0 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisSentinel.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisSentinel.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisStandalone.java b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisStandalone.java index e891b40..12c360a 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisStandalone.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/jedis/JedisStandalone.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/conductor/redis/jedis/OrkesJedisProxy.java b/persistence/src/main/java/com/netflix/conductor/redis/jedis/OrkesJedisProxy.java index 9e92c33..451222b 100644 --- a/persistence/src/main/java/com/netflix/conductor/redis/jedis/OrkesJedisProxy.java +++ b/persistence/src/main/java/com/netflix/conductor/redis/jedis/OrkesJedisProxy.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/dyno/connectionpool/Host.java b/persistence/src/main/java/com/netflix/dyno/connectionpool/Host.java index 4e90697..1fa48fe 100644 --- a/persistence/src/main/java/com/netflix/dyno/connectionpool/Host.java +++ b/persistence/src/main/java/com/netflix/dyno/connectionpool/Host.java @@ -1,10 +1,10 @@ /* * Copyright 2011 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/dyno/connectionpool/HostBuilder.java b/persistence/src/main/java/com/netflix/dyno/connectionpool/HostBuilder.java index 4934374..d31f5b9 100644 --- a/persistence/src/main/java/com/netflix/dyno/connectionpool/HostBuilder.java +++ b/persistence/src/main/java/com/netflix/dyno/connectionpool/HostBuilder.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/main/java/com/netflix/dyno/connectionpool/HostSupplier.java b/persistence/src/main/java/com/netflix/dyno/connectionpool/HostSupplier.java index d4075ce..bdfed2b 100644 --- a/persistence/src/main/java/com/netflix/dyno/connectionpool/HostSupplier.java +++ b/persistence/src/main/java/com/netflix/dyno/connectionpool/HostSupplier.java @@ -1,10 +1,10 @@ /* * Copyright 2011 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/common/config/TestObjectMapperConfiguration.java b/persistence/src/test/java/com/netflix/conductor/common/config/TestObjectMapperConfiguration.java index 23b7d80..e2b9ee3 100644 --- a/persistence/src/test/java/com/netflix/conductor/common/config/TestObjectMapperConfiguration.java +++ b/persistence/src/test/java/com/netflix/conductor/common/config/TestObjectMapperConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/dao/ExecutionDAOTest.java b/persistence/src/test/java/com/netflix/conductor/dao/ExecutionDAOTest.java index 3ebcec8..b8f0ba1 100644 --- a/persistence/src/test/java/com/netflix/conductor/dao/ExecutionDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/dao/ExecutionDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/dao/PollDataDAOTest.java b/persistence/src/test/java/com/netflix/conductor/dao/PollDataDAOTest.java index 1af3326..5906ccc 100644 --- a/persistence/src/test/java/com/netflix/conductor/dao/PollDataDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/dao/PollDataDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/dao/BaseDynoDAOTest.java b/persistence/src/test/java/com/netflix/conductor/redis/dao/BaseDynoDAOTest.java index a6a1db8..af699c4 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/dao/BaseDynoDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/dao/BaseDynoDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAOTest.java b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAOTest.java index ea79af8..51f7535 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisEventHandlerDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisExecutionDAOTest.java b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisExecutionDAOTest.java index fed951a..e34224d 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisExecutionDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisExecutionDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisMetadataDAOTest.java b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisMetadataDAOTest.java index 95522d7..e7fb871 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisMetadataDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisMetadataDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisPollDataDAOTest.java b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisPollDataDAOTest.java index 9fb8364..0324f9d 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisPollDataDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisPollDataDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisRateLimitDAOTest.java b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisRateLimitDAOTest.java index bff9384..a8fec64 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisRateLimitDAOTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/dao/RedisRateLimitDAOTest.java @@ -1,10 +1,10 @@ /* * Copyright 2021 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/jedis/ConfigurationHostSupplierTest.java b/persistence/src/test/java/com/netflix/conductor/redis/jedis/ConfigurationHostSupplierTest.java index 835dcf9..e7c8126 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/jedis/ConfigurationHostSupplierTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/jedis/ConfigurationHostSupplierTest.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisClusterTest.java b/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisClusterTest.java index 188d38c..8467113 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisClusterTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisClusterTest.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisSentinelTest.java b/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisSentinelTest.java index b682813..7ea0fcc 100644 --- a/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisSentinelTest.java +++ b/persistence/src/test/java/com/netflix/conductor/redis/jedis/JedisSentinelTest.java @@ -1,10 +1,10 @@ /* * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/com/netflix/conductor/core/execution/OrkesWorkflowExecutor.java b/server/src/main/java/com/netflix/conductor/core/execution/OrkesWorkflowExecutor.java index 1daf196..b58b8c3 100644 --- a/server/src/main/java/com/netflix/conductor/core/execution/OrkesWorkflowExecutor.java +++ b/server/src/main/java/com/netflix/conductor/core/execution/OrkesWorkflowExecutor.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the @@ -47,7 +47,6 @@ import com.netflix.conductor.service.ExecutionLockService; import io.orkes.conductor.id.TimeBasedUUIDGenerator; -import io.orkes.conductor.metrics.MetricsCollector; import com.google.common.util.concurrent.ThreadFactoryBuilder; import lombok.extern.slf4j.Slf4j; @@ -121,8 +120,6 @@ public boolean offer(Runnable runnable) { log.info("OrkesWorkflowExecutor initialized"); } - - @Override public void retry(String workflowId, boolean resumeSubworkflowTasks) { WorkflowModel workflowModel = orkesExecutionDAOFacade.getWorkflowModel(workflowId, true); diff --git a/server/src/main/java/io/orkes/conductor/OrkesConductorApplication.java b/server/src/main/java/io/orkes/conductor/OrkesConductorApplication.java index 3a81fde..8041104 100644 --- a/server/src/main/java/io/orkes/conductor/OrkesConductorApplication.java +++ b/server/src/main/java/io/orkes/conductor/OrkesConductorApplication.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/config/AWSCredentialsConfiguration.java b/server/src/main/java/io/orkes/conductor/config/AWSCredentialsConfiguration.java index 648ea22..d942669 100644 --- a/server/src/main/java/io/orkes/conductor/config/AWSCredentialsConfiguration.java +++ b/server/src/main/java/io/orkes/conductor/config/AWSCredentialsConfiguration.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/config/SecurityDisabledConfig.java b/server/src/main/java/io/orkes/conductor/config/SecurityDisabledConfig.java index b079384..4384f1e 100644 --- a/server/src/main/java/io/orkes/conductor/config/SecurityDisabledConfig.java +++ b/server/src/main/java/io/orkes/conductor/config/SecurityDisabledConfig.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/execution/tasks/HttpSync.java b/server/src/main/java/io/orkes/conductor/execution/tasks/HttpSync.java index 8d037bb..deb563a 100644 --- a/server/src/main/java/io/orkes/conductor/execution/tasks/HttpSync.java +++ b/server/src/main/java/io/orkes/conductor/execution/tasks/HttpSync.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/execution/tasks/OrkesRestTemplateProvider.java b/server/src/main/java/io/orkes/conductor/execution/tasks/OrkesRestTemplateProvider.java index a22e701..4ec1e19 100644 --- a/server/src/main/java/io/orkes/conductor/execution/tasks/OrkesRestTemplateProvider.java +++ b/server/src/main/java/io/orkes/conductor/execution/tasks/OrkesRestTemplateProvider.java @@ -1,10 +1,10 @@ /* - * Copyright 2020 Netflix, Inc. + * Copyright 2020 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the @@ -12,9 +12,10 @@ */ package io.orkes.conductor.execution.tasks; -import com.netflix.conductor.tasks.http.HttpTask; -import com.netflix.conductor.tasks.http.providers.RestTemplateProvider; -import lombok.AllArgsConstructor; +import java.time.Duration; +import java.util.List; +import java.util.Optional; + import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.web.client.RestTemplateBuilder; @@ -24,13 +25,14 @@ import org.springframework.stereotype.Component; import org.springframework.web.client.RestTemplate; -import java.time.Duration; -import java.util.List; -import java.util.Optional; +import com.netflix.conductor.tasks.http.HttpTask; +import com.netflix.conductor.tasks.http.providers.RestTemplateProvider; + +import lombok.AllArgsConstructor; /** - * Provider for a customized RestTemplateBuilder. This class provides a default {@link RestTemplateBuilder} which can be - * configured or extended as needed. + * Provider for a customized RestTemplateBuilder. This class provides a default {@link + * RestTemplateBuilder} which can be configured or extended as needed. */ @Component @Primary @@ -49,22 +51,28 @@ private static class RestTemplateHolder { private final int defaultConnectTimeout; @Autowired - public OrkesRestTemplateProvider(@Value("${conductor.tasks.http.readTimeout:250ms}") Duration readTimeout, - @Value("${conductor.tasks.http.connectTimeout:250ms}") Duration connectTimeout, - Optional interceptor) { + public OrkesRestTemplateProvider( + @Value("${conductor.tasks.http.readTimeout:250ms}") Duration readTimeout, + @Value("${conductor.tasks.http.connectTimeout:250ms}") Duration connectTimeout, + Optional interceptor) { this.defaultReadTimeout = (int) readTimeout.toMillis(); this.defaultConnectTimeout = (int) connectTimeout.toMillis(); - this.threadLocalRestTemplate = ThreadLocal.withInitial(() -> - { - RestTemplate restTemplate = new RestTemplate(); - HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory(); - requestFactory.setReadTimeout(defaultReadTimeout); - requestFactory.setConnectTimeout(defaultConnectTimeout); - restTemplate.setRequestFactory(requestFactory); - interceptor.ifPresent(it -> addInterceptor(restTemplate, it)); - return new RestTemplateHolder(restTemplate, requestFactory, defaultReadTimeout, defaultConnectTimeout); - }); - + this.threadLocalRestTemplate = + ThreadLocal.withInitial( + () -> { + RestTemplate restTemplate = new RestTemplate(); + HttpComponentsClientHttpRequestFactory requestFactory = + new HttpComponentsClientHttpRequestFactory(); + requestFactory.setReadTimeout(defaultReadTimeout); + requestFactory.setConnectTimeout(defaultConnectTimeout); + restTemplate.setRequestFactory(requestFactory); + interceptor.ifPresent(it -> addInterceptor(restTemplate, it)); + return new RestTemplateHolder( + restTemplate, + requestFactory, + defaultReadTimeout, + defaultConnectTimeout); + }); } @Override @@ -74,7 +82,8 @@ public RestTemplate getRestTemplate(HttpTask.Input input) { HttpComponentsClientHttpRequestFactory requestFactory = holder.requestFactory; int newReadTimeout = Optional.ofNullable(input.getReadTimeOut()).orElse(defaultReadTimeout); - int newConnectTimeout = Optional.ofNullable(input.getConnectionTimeOut()).orElse(defaultConnectTimeout); + int newConnectTimeout = + Optional.ofNullable(input.getConnectionTimeOut()).orElse(defaultConnectTimeout); if (newReadTimeout != holder.readTimeout || newConnectTimeout != holder.connectTimeout) { holder.readTimeout = newReadTimeout; holder.connectTimeout = newConnectTimeout; @@ -85,7 +94,8 @@ public RestTemplate getRestTemplate(HttpTask.Input input) { return restTemplate; } - private void addInterceptor(RestTemplate restTemplate, ClientHttpRequestInterceptor interceptor) { + private void addInterceptor( + RestTemplate restTemplate, ClientHttpRequestInterceptor interceptor) { List interceptors = restTemplate.getInterceptors(); if (!interceptors.contains(interceptor)) { interceptors.add(interceptor); diff --git a/server/src/main/java/io/orkes/conductor/execution/tasks/SubWorkflowSync.java b/server/src/main/java/io/orkes/conductor/execution/tasks/SubWorkflowSync.java index 5efadd1..ccf99cf 100644 --- a/server/src/main/java/io/orkes/conductor/execution/tasks/SubWorkflowSync.java +++ b/server/src/main/java/io/orkes/conductor/execution/tasks/SubWorkflowSync.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/execution/tasks/mapper/OrkesForkJoinDynamicTaskMapper.java b/server/src/main/java/io/orkes/conductor/execution/tasks/mapper/OrkesForkJoinDynamicTaskMapper.java index b0cc772..a3ca7f5 100644 --- a/server/src/main/java/io/orkes/conductor/execution/tasks/mapper/OrkesForkJoinDynamicTaskMapper.java +++ b/server/src/main/java/io/orkes/conductor/execution/tasks/mapper/OrkesForkJoinDynamicTaskMapper.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/rest/VersionResource.java b/server/src/main/java/io/orkes/conductor/rest/VersionResource.java index 5b32eb8..6bb7248 100644 --- a/server/src/main/java/io/orkes/conductor/rest/VersionResource.java +++ b/server/src/main/java/io/orkes/conductor/rest/VersionResource.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/rest/WorkflowResourceSync.java b/server/src/main/java/io/orkes/conductor/rest/WorkflowResourceSync.java index f9e39ad..be86452 100644 --- a/server/src/main/java/io/orkes/conductor/rest/WorkflowResourceSync.java +++ b/server/src/main/java/io/orkes/conductor/rest/WorkflowResourceSync.java @@ -1,21 +1,38 @@ +/* + * Copyright 2023 Orkes, Inc. + *

+ * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + *

+ * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt + *

+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + */ package io.orkes.conductor.rest; -import com.google.common.util.concurrent.Uninterruptibles; +import java.util.ArrayList; +import java.util.concurrent.*; + +import javax.annotation.PostConstruct; + +import org.springframework.web.bind.annotation.*; + import com.netflix.conductor.common.metadata.workflow.StartWorkflowRequest; import com.netflix.conductor.common.run.Workflow; import com.netflix.conductor.service.WorkflowService; + import io.orkes.conductor.common.model.WorkflowRun; + +import com.google.common.util.concurrent.Uninterruptibles; import io.swagger.v3.oas.annotations.Operation; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; -import org.springframework.web.bind.annotation.*; - -import javax.annotation.PostConstruct; -import java.util.ArrayList; -import java.util.concurrent.*; import static com.netflix.conductor.rest.config.RequestMappingConstants.WORKFLOW; + import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE; @RestController @@ -28,7 +45,8 @@ public class WorkflowResourceSync { private final WorkflowService workflowService; - private final ScheduledExecutorService executionMonitor = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors() * 2); + private final ScheduledExecutorService executionMonitor = + Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors() * 2); @PostConstruct public void startMonitor() { @@ -50,16 +68,24 @@ public WorkflowRun executeWorkflow( String workflowId = workflowService.startWorkflow(request); request.getInput().put(REQUEST_ID_KEY, requestId); Workflow workflow = workflowService.getExecutionStatus(workflowId, true); - if(workflow.getStatus().isTerminal() || workflow.getTasks().stream().anyMatch(t -> t.getReferenceTaskName().equalsIgnoreCase(waitUntilTaskRef))) { + if (workflow.getStatus().isTerminal() + || workflow.getTasks().stream() + .anyMatch( + t -> t.getReferenceTaskName().equalsIgnoreCase(waitUntilTaskRef))) { return toWorkflowRun(workflow); } - int maxTimeInMilis = 5_000; //5 sec - int sleepTime = 100; //millis + int maxTimeInMilis = 5_000; // 5 sec + int sleepTime = 100; // millis int loopCount = maxTimeInMilis / sleepTime; for (int i = 0; i < loopCount; i++) { Uninterruptibles.sleepUninterruptibly(100, TimeUnit.MILLISECONDS); workflow = workflowService.getExecutionStatus(workflowId, true); - if(workflow.getStatus().isTerminal() || workflow.getTasks().stream().anyMatch(t -> t.getReferenceTaskName().equalsIgnoreCase(waitUntilTaskRef))) { + if (workflow.getStatus().isTerminal() + || workflow.getTasks().stream() + .anyMatch( + t -> + t.getReferenceTaskName() + .equalsIgnoreCase(waitUntilTaskRef))) { return toWorkflowRun(workflow); } } @@ -80,7 +106,7 @@ public static WorkflowRun toWorkflowRun(Workflow workflow) { run.setTasks(new ArrayList<>()); workflow.getTasks().forEach(task -> run.getTasks().add(task)); run.setPriority(workflow.getPriority()); - if(workflow.getUpdateTime() != null) { + if (workflow.getUpdateTime() != null) { run.setUpdateTime(workflow.getUpdateTime()); } run.setStatus(Workflow.WorkflowStatus.valueOf(workflow.getStatus().name())); diff --git a/server/src/main/java/io/orkes/conductor/server/service/OrkesSweeperProperties.java b/server/src/main/java/io/orkes/conductor/server/service/OrkesSweeperProperties.java index 91df3d5..9cec440 100644 --- a/server/src/main/java/io/orkes/conductor/server/service/OrkesSweeperProperties.java +++ b/server/src/main/java/io/orkes/conductor/server/service/OrkesSweeperProperties.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/server/service/OrkesWorkflowSweeper.java b/server/src/main/java/io/orkes/conductor/server/service/OrkesWorkflowSweeper.java index 6611d24..21df5c8 100644 --- a/server/src/main/java/io/orkes/conductor/server/service/OrkesWorkflowSweeper.java +++ b/server/src/main/java/io/orkes/conductor/server/service/OrkesWorkflowSweeper.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the diff --git a/server/src/main/java/io/orkes/conductor/ui/UIContextGenerator.java b/server/src/main/java/io/orkes/conductor/ui/UIContextGenerator.java index 45da10c..e7eb9a0 100644 --- a/server/src/main/java/io/orkes/conductor/ui/UIContextGenerator.java +++ b/server/src/main/java/io/orkes/conductor/ui/UIContextGenerator.java @@ -1,10 +1,10 @@ /* * Copyright 2022 Orkes, Inc. *

- * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * Licensed under the Orkes Community License (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at *

- * http://www.apache.org/licenses/LICENSE-2.0 + * https://github.com/orkes-io/licenses/blob/main/community/LICENSE.txt *

* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the