From 4c39802ede7ac5b52d676704321aded6bd26d8b5 Mon Sep 17 00:00:00 2001 From: rbeker-BMC Date: Mon, 4 Mar 2024 11:47:13 +0200 Subject: [PATCH] Events behavior - issue #29 --- .../notebooks/jobproperties.ipynb.txt | 12 +- docs/aapi.html | 457 +++++++---- docs/aapi.integration_factory.html | 714 ++++++++++++++++-- docs/genindex.html | 292 ++++++- docs/notebooks/jobproperties.html | 12 +- docs/notebooks/jobproperties.ipynb | 12 +- docs/objects.inv | Bin 84156 -> 86188 bytes docs/searchindex.js | 2 +- .../source/notebooks/jobproperties.ipynb | 12 +- setup.py | 2 +- src/aapi/__init__.py | 2 +- src/aapi/addevents.py | 13 +- src/aapi/basefolder.py | 15 +- src/aapi/bases.py | 2 + src/aapi/deleteevents.py | 13 +- src/aapi/event.py | 32 +- src/aapi/folderjobbase.py | 11 +- src/aapi/job.py | 35 +- src/aapi/waitforevents.py | 13 +- src/ctm_python_client/__init__.py | 2 +- src/ctm_python_client/core/workflow.py | 19 + tests/test_sanity.py | 2 +- 22 files changed, 1399 insertions(+), 275 deletions(-) diff --git a/docs/_sources/notebooks/jobproperties.ipynb.txt b/docs/_sources/notebooks/jobproperties.ipynb.txt index 647a28a..2c1cd2d 100644 --- a/docs/_sources/notebooks/jobproperties.ipynb.txt +++ b/docs/_sources/notebooks/jobproperties.ipynb.txt @@ -1015,9 +1015,9 @@ "metadata": {}, "outputs": [], "source": [ - "waitForEventList = WaitForEvents(\"WaitForEvent\", events=[Condition(event=\"e1\"),Condition(event=\"e2\"), Condition(event=\"e3\", date=Event.Date.AnyDate)])\n", + "waitForEventList = WaitForEvents([Event(event=\"e1\"), Event(event=\"e2\"), Event(event=\"e3\", date=Event.Date.AnyDate)])\n", "job = JobCommand('Job1', command='echo Hello')\n", - "job.wait_for_events_list.insert(0, waitForEventList)" + "job.event_list.append(waitForEventList)" ] }, { @@ -1035,9 +1035,9 @@ "metadata": {}, "outputs": [], "source": [ - "addEventListObject = AddEvents('eventsToAdd', events=[ConditionOutAdd(event=\"e4\",date=Event.Date.NoDate)])\n", + "addEventListObject = AddEvents([EventOutAdd(event=\"e4\",date=Event.Date.NoDate)])\n", "job = JobCommand('Job1', command='echo Hello')\n", - "job.add_events_list.insert(0, waitForEventList)" + "job.event_list.append(addEventListObject)" ] }, { @@ -1055,9 +1055,9 @@ "metadata": {}, "outputs": [], "source": [ - "deleteEventListObject = DeleteEvents('eventsToDelete', events=[ConditionOutDelete(event=\"e5\",date=Event.Date.NextOrderDate)])\n", + "deleteEventListObject = DeleteEvents([EventOutDelete(event=\"e5\",date=Event.Date.NextOrderDate)])\n", "job = JobCommand('Job1', command='echo Hello')\n", - "job.delete_events_list.insert(0, deleteEventListObject)" + "job.event_list.append(deleteEventListObject)" ] } ], diff --git a/docs/aapi.html b/docs/aapi.html index efb127b..8bb454d 100644 --- a/docs/aapi.html +++ b/docs/aapi.html @@ -225,6 +225,13 @@

Subpackagesaapi.integration_factory package -
  • failure_tolerance (aapi.integration_factory.jobs.JobAwsCloudFormation attribute) +
  • failure_tolarance (aapi.integration_factory.jobs.JobAwsDynamoDB attribute) +
    • +
  • failure_tolerance (aapi.integration_factory.jobs.JobAirbyte attribute)
    • -
  • function_name (aapi.integration_factory.jobs.JobAzureFunctions attribute) +
  • function_name (aapi.integration_factory.jobs.JobAwsLambda attribute) @@ -4189,6 +4299,8 @@

    G

    • - +
  • kms_key (aapi.integration_factory.jobs.JobAwsAthena attribute) +
    • +
  • kubernetes_cluster_url (aapi.integration_factory.connection_profiles.ConnectionProfileKubernetes attribute)
    • @@ -5530,6 +5680,8 @@

    L

  • L (aapi.period.Period.Period attribute)
  • lake_name (aapi.integration_factory.jobs.JobGCPDataplex attribute) +
    • +
  • lambda_url (aapi.integration_factory.connection_profiles.ConnectionProfileAwsLambda attribute)
  • language (aapi.connectionprofile.ConnectionProfileSAP attribute) @@ -5590,11 +5742,11 @@

    L

  • Like (aapi.ifbase.IfVariableValue.Operator attribute) -
    • -
  • line_comment (aapi.driver.DriverJdbcDatabase attribute)
  • s3_acl_option (aapi.integration_factory.jobs.JobAwsAthena attribute)
    • -
  • s3_bucket_name (aapi.job.JobFileTransfer attribute) +
  • s3_bucket_name (aapi.integration_factory.jobs.JobAwsDynamoDB attribute) + +
  • s3_bucket_name_dest (aapi.job.JobFileTransfer attribute)
  • s3_bucket_name_src (aapi.job.JobFileTransfer attribute) +
    • +
  • s3_bucket_owner_id (aapi.integration_factory.jobs.JobAwsDynamoDB attribute) +
    • +
  • s3_path_prefix (aapi.integration_factory.jobs.JobAwsDynamoDB attribute)
  • s3_storage_type (aapi.connectionprofile.ConnectionProfileFileTransferS3 attribute)
    • @@ -8593,6 +8791,8 @@

    S

  • service_priority (aapi.job.JobSLAManagement attribute)
  • service_role (aapi.integration_factory.jobs.JobAwsEMR attribute) +
    • +
  • service_token_file (aapi.integration_factory.connection_profiles.ConnectionProfileKubernetes attribute)
  • service_type (aapi.connectionprofile.ConnectionProfileWebServices attribute)
    • @@ -8650,6 +8850,8 @@

    S

  • (aapi.integration_factory.jobs.JobSnowflakeIdP attribute)
    • +
  • show_results (aapi.integration_factory.jobs.JobAirbyte attribute) +
  • show_workflow_results (aapi.integration_factory.jobs.JobGCPWorkflows attribute)
  • sid (aapi.connectionprofile.ConnectionProfileDatabaseOracleSID attribute) @@ -9039,6 +9241,12 @@

    S

  • state_machine_arn (aapi.integration_factory.jobs.JobAwsStepFunctions attribute)
  • statement (aapi.ifbase.IfOutput attribute) + +
    • +
  • statement_parameters (aapi.integration_factory.jobs.JobAwsDynamoDB attribute)
  • statement_separator (aapi.driver.DriverJdbcDatabase attribute)
    • @@ -9066,9 +9274,11 @@

    S

  • (aapi.integration_factory.jobs.JobSnowflakeIdP attribute)
    • -
  • status_polling_frequency (aapi.integration_factory.jobs.JobAlteryxTrifacta attribute) +
  • status_polling_frequency (aapi.integration_factory.jobs.JobAirbyte attribute)
  • Tab (aapi.captureoutput.ActionCaptureOutput.ForwardBy.Delimiter attribute) +
    • +
  • table_arn (aapi.integration_factory.jobs.JobAwsDynamoDB attribute) +
    • +
  • table_creation_parameters (aapi.integration_factory.jobs.JobAwsDynamoDB attribute)
  • table_name (aapi.integration_factory.jobs.JobAwsAthena attribute) +
    • - - - + +
  • user_ocid (aapi.integration_factory.connection_profiles.ConnectionProfileOCIVM attribute) +
  • username (aapi.connectionprofile.ConnectionProfileAWS.ProxySettings attribute)