Skip to content

Commit

Permalink
Merge pull request #254 from lincc-frameworks/lean_sync
Browse files Browse the repository at this point in the history
Reduce scope of sync_tables
  • Loading branch information
dougbrn authored Oct 6, 2023
2 parents 0f962c5 + 551af41 commit 5a93408
Show file tree
Hide file tree
Showing 11 changed files with 275 additions and 909 deletions.
7 changes: 6 additions & 1 deletion docs/examples/rrlyr-period.ipynb
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,12 @@
"name": "python",
"nbconvert_exporter": "python",
"pygments_lexer": "ipython2",
"version": "2.7.6"
"version": "3.10.11"
},
"vscode": {
"interpreter": {
"hash": "83afbb17b435d9bf8b0d0042367da76f26510da1c5781f0ff6e6c518eab621ec"
}
}
},
"nbformat": 4,
Expand Down
1 change: 1 addition & 0 deletions docs/gettingstarted/quickstart.ipynb
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@
"metadata": {},
"outputs": [],
"source": [
"ens.calc_nobs() # calculates number of observations, produces \"nobs_total\" column \n",
"ens = ens.query(\"nobs_total >= 95 & nobs_total <= 105\", \"object\")"
]
},
Expand Down
44 changes: 22 additions & 22 deletions docs/tutorials/binning_slowly_changing_sources.ipynb
Original file line number Diff line number Diff line change
Expand Up @@ -60,9 +60,9 @@
"outputs": [],
"source": [
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 500)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 500)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand Down Expand Up @@ -90,9 +90,9 @@
"source": [
"ens.bin_sources(time_window=7.0, offset=0.0)\n",
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 500)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 500)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand Down Expand Up @@ -120,9 +120,9 @@
"source": [
"ens.bin_sources(time_window=28.0, offset=0.0, custom_aggr={\"midPointTai\": \"min\"})\n",
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 500)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 500)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand Down Expand Up @@ -150,9 +150,9 @@
"ens.from_source_dict(rows, column_mapper=cmap)\n",
"\n",
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand All @@ -179,9 +179,9 @@
"ens.bin_sources(time_window=1.0, offset=0.0)\n",
"\n",
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand Down Expand Up @@ -209,9 +209,9 @@
"ens.bin_sources(time_window=1.0, offset=0.5)\n",
"\n",
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand Down Expand Up @@ -259,9 +259,9 @@
"ens.bin_sources(time_window=1.0, offset=0.5)\n",
"\n",
"fig, ax = plt.subplots(1, 1)\n",
"_ = ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"_ = ax.set_xlabel(\"Time (MJD)\")\n",
"_ = ax.set_ylabel(\"Source Count\")"
"ax.hist(ens._source[\"midPointTai\"].compute().tolist(), 60)\n",
"ax.set_xlabel(\"Time (MJD)\")\n",
"ax.set_ylabel(\"Source Count\")"
]
},
{
Expand Down Expand Up @@ -290,7 +290,7 @@
"name": "python",
"nbconvert_exporter": "python",
"pygments_lexer": "ipython3",
"version": "3.10.12"
"version": "3.10.6"
},
"vscode": {
"interpreter": {
Expand Down
528 changes: 40 additions & 488 deletions docs/tutorials/structure_function_showcase.ipynb

Large diffs are not rendered by default.

3 changes: 1 addition & 2 deletions docs/tutorials/tape_datasets.ipynb
Original file line number Diff line number Diff line change
Expand Up @@ -85,8 +85,7 @@
" flux_col=\"psFlux\",\n",
" err_col=\"psFluxErr\",\n",
" band_col=\"filterName\",\n",
" nobs_total_col=\"nobs_total\",\n",
" nobs_band_cols=[\"nobs_g\", \"nobs_r\"])\n",
")\n",
"\n",
"# Read in data from a parquet file that contains source (timeseries) data\n",
"ens.from_parquet(source_file=f\"{rel_path}/source/test_source.parquet\",\n",
Expand Down
316 changes: 50 additions & 266 deletions docs/tutorials/working_with_the_ensemble.ipynb

Large diffs are not rendered by default.

Loading

0 comments on commit 5a93408

Please sign in to comment.